class AdvancedSneakersActiveJob::Publisher

Private Instance Methods

log_message() click to toggle source
# File lib/advanced_sneakers_activejob/publisher.rb, line 17
def log_message
  logger.debug do
    "Publishing <#{message}> to [#{@exchange_name}] with routing_key [#{message_options[:routing_key]}]"
  end
end
on_message_return(return_info, properties, message) click to toggle source
Calls superclass method
# File lib/advanced_sneakers_activejob/publisher.rb, line 23
def on_message_return(return_info, properties, message)
  if config_handle_unrouted_messages
    super
  else
    logger.warn do
      "Message is not routed! #{{ message: message, return_info: return_info, properties: properties }}"
    end
  end
end