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