Sha256: f5ae79b3769e2ecf7a522c5097321de192b027822b2d29da1dfae47d6534fe9f
Contents?: true
Size: 541 Bytes
Versions: 14
Compression:
Stored size: 541 Bytes
Contents
class Freddy
module Producers
class ReplyProducer
CONTENT_TYPE = 'application/json'.freeze
def initialize(channel, logger)
@logger = logger
@exchange = channel.default_exchange
end
def produce(destination, payload, properties)
Producers.log_send_event(@logger, payload, destination)
properties = properties.merge(
routing_key: destination, content_type: CONTENT_TYPE
)
@exchange.publish Payload.dump(payload), properties
end
end
end
end
Version data entries
14 entries across 14 versions & 2 rubygems