Class: Emque::Consuming::Consumer

Inherits:
Object
  • Object
show all
Defined in:
lib/emque/consuming/consumer.rb,
lib/emque/consuming/consumer/common.rb

Defined Under Namespace

Modules: Common

Instance Method Summary collapse

Instance Method Details

#process(message) ⇒ Object 



12
13
14
15
16
17
 
# File 'lib/emque/consuming/consumer.rb', line 12

def process(message)
  pipe(message, :through => [:parse, :route])
rescue => e
  handle_error(e, message)
  raise
end