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