class Freddy::MessageHandlerAdapters::RequestHandler
Public Class Methods
new(producer)
click to toggle source
# File lib/freddy/message_handler_adapaters.rb, line 31 def initialize(producer) @producer = producer end
Public Instance Methods
error(delivery, response)
click to toggle source
# File lib/freddy/message_handler_adapaters.rb, line 39 def error(delivery, response) send_response(delivery, response, type: 'error') end
success(delivery, response)
click to toggle source
# File lib/freddy/message_handler_adapaters.rb, line 35 def success(delivery, response) send_response(delivery, response, type: 'success') end
Private Instance Methods
send_response(delivery, response, opts = {})
click to toggle 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