Sha256: 1a84a4be79f0769813614844d10e12eb154a94e7d23a32cc30bf9a234850e082
Contents?: true
Size: 850 Bytes
Versions: 98
Compression:
Stored size: 850 Bytes
Contents
module ActivePublisher
# Publish a message asynchronously to RabbitMQ.
#
# Asynchronous is designed to do two things:
# 1. Introduce the idea of a durable retry should the RabbitMQ connection disconnect.
# 2. Provide a higher-level pattern for fire-and-forget publishing.
#
# @param [String] route The routing key to use for this message.
# @param [String] payload The message you are sending. Should already be encoded as a string.
# @param [String] exchange The exchange you want to publish to.
# @param [Hash] options hash to set message parameters (e.g. headers).
def self.publish_async(route, payload, exchange_name, options = {})
::ActivePublisher::Async.publisher_adapter.publish(route, payload, exchange_name, options)
end
module Async
class << self
attr_accessor :publisher_adapter
end
end
end
Version data entries
98 entries across 98 versions & 1 rubygems