class Freddy::MessageHandlerAdapters::RequestHandler
Public Class Methods
Source
# File lib/freddy/message_handler_adapaters.rb, line 31 def initialize(producer) @producer = producer end
Public Instance Methods
Source
# File lib/freddy/message_handler_adapaters.rb, line 39 def error(delivery, response) send_response(delivery, response, type: 'error') end
Source
# File lib/freddy/message_handler_adapaters.rb, line 35 def success(delivery, response) send_response(delivery, response, type: 'success') end
Private Instance Methods
Source
# File lib/freddy/message_handler_adapaters.rb, line 45 def send_response(delivery, response, opts = {}) @producer.produce delivery.reply_to.force_encoding('utf-8'), response, { correlation_id: delivery.correlation_id }.merge(opts) end