Sha256: beeeec76477fdc882662c4e863eafc5025af41b36ab9398945699ba3f3f8c458
Contents?: true
Size: 786 Bytes
Versions: 42
Compression:
Stored size: 786 Bytes
Contents
module Pwwka
class SendMessageAsyncJob
extend Pwwka::Logging
@queue = 'pwwka_send_message_async'
extend Resque::Plugins::ExponentialBackoff rescue nil # Optional
@backoff_strategy = Pwwka.configuration.send_message_resque_backoff_strategy
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
end
end
Version data entries
42 entries across 42 versions & 1 rubygems