class Freddy::MessageHandlerAdapters::RequestHandler
Public Class Methods
new(producer)
click to toggle source
# File lib/freddy/message_handler_adapaters.rb, line 29 def initialize(producer) @producer = producer end
Public Instance Methods
error(delivery, response)
click to toggle source
# File lib/freddy/message_handler_adapaters.rb, line 37 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 33 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 43 def send_response(delivery, response, opts = {}) @producer.produce delivery.reply_to.force_encoding('utf-8'), response, { correlation_id: delivery.correlation_id }.merge(opts) end