class Pwwka::SendMessageAsyncSidekiqJob
Public Instance Methods
perform(payload, routing_key, options = {})
click to toggle source
# File lib/pwwka/send_message_async_sidekiq_job.rb, line 14 def perform(payload, routing_key, options = {}) type = options["type"] message_id = options["message_id"] || "auto_generate" headers = options["headers"] logger.info("Sending message async #{routing_key}, #{payload}") message_id = message_id.to_sym if message_id == "auto_generate" Pwwka::Transmitter.send_message!( payload, routing_key, type: type, message_id: message_id, headers: headers, on_error: :raise, ) end