Class: Freddy::MessageHandlers::StandardMessageHandler

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

Instance Method Summary collapse

Constructor Details

#initialize(producer, logger) ⇒ StandardMessageHandler

Returns a new instance of StandardMessageHandler.



8
9
10
11
 
# File 'lib/freddy/message_handlers.rb', line 8

def initialize(producer, logger)
  @producer = producer
  @logger = logger
end

Instance Method Details

#error ⇒ Object 



25
26
27
 
# File 'lib/freddy/message_handlers.rb', line 25

def error(*)
  # NOP
end

#handle_message(payload, msg_handler, &block) ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/freddy/message_handlers.rb', line 13

def handle_message(payload, msg_handler, &block)
  block.call payload, msg_handler
rescue Exception => e
  destination = msg_handler.destination
  @logger.error "Exception occured while processing message from #{destination}: #{Freddy.format_exception(e)}"
  Freddy.notify_exception(e, destination: destination)
end

#success ⇒ Object 



21
22
23
 
# File 'lib/freddy/message_handlers.rb', line 21

def success(*)
  # NOP
end