Skip to content

Commit

Permalink
chore: improve log messages
Browse files Browse the repository at this point in the history
  • Loading branch information
owen2345 committed Jun 29, 2021
1 parent 6568126 commit a7c67be
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions lib/pub_sub_model_sync/message_publisher.rb
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ def publish!(payload, &block)
end

def connector_publish(payload)
log("Publishing message #{payload.inspect}...") if config.debug
log("Publishing message #{[payload]}...") if config.debug
connector.publish(payload)
log("Published message: #{[payload]}")
config.on_after_publish.call(payload)
Expand All @@ -99,7 +99,7 @@ def publish(payload, &block)

def ensure_publish(payload)
cancelled = config.on_before_publish.call(payload) == :cancel
log("Publish cancelled by config.on_before_publish: #{payload}") if config.debug && cancelled
log("Publish cancelled by config.on_before_publish: #{[payload]}") if config.debug && cancelled
!cancelled
end

Expand All @@ -110,7 +110,7 @@ def ordering_key_for(payload)
def ensure_model_publish(model, action, payload)
res_before = model.ps_before_publish(action, payload)
cancelled = res_before == :cancel
log("Publish cancelled by model.ps_before_publish: #{payload}") if config.debug && cancelled
log("Publish cancelled by model.ps_before_publish: #{[payload]}") if config.debug && cancelled
!cancelled
end

Expand Down

0 comments on commit a7c67be

Please sign in to comment.