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