class Pwwka::SendMessageAsyncJob
Public Class Methods
perform(payload, routing_key, options = {})
click to toggle source
# File lib/pwwka/send_message_async_job.rb, line 11 def self.perform(payload, routing_key, options = {}) type = options["type"] message_id = options["message_id"] || "auto_generate" headers = options["headers"] 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