Class: Freddy::MessageHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/freddy/message_handler.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(adapter, delivery) ⇒ MessageHandler 



5
6
7
8
9
 
# File 'lib/freddy/message_handler.rb', line 5

def initialize(adapter, delivery)
  @adapter = adapter
  @delivery = delivery
  @correlation_id = @delivery.correlation_id
end

Instance Attribute Details

#correlation_id ⇒ Object (readonly)

Returns the value of attribute correlation_id.



3
4
5
 
# File 'lib/freddy/message_handler.rb', line 3

def correlation_id
  @correlation_id
end

Instance Method Details

#error(error = {error: "Couldn't process message"}) ⇒ Object 



15
16
17
 
# File 'lib/freddy/message_handler.rb', line 15

def error(error = {error: "Couldn't process message"})
  @adapter.error(@delivery.reply_to, error)
end

#success(response = nil) ⇒ Object 



11
12
13
 
# File 'lib/freddy/message_handler.rb', line 11

def success(response = nil)
  @adapter.success(@delivery.reply_to, response)
end