Method: EmPipelines::Message#on_consumed

Defined in:
lib/empipelines/message.rb

#on_consumed(callback = nil, &callback_block) ⇒ Object 



34
35
36
 
# File 'lib/empipelines/message.rb', line 34

def on_consumed(callback=nil, &callback_block)
  @consumed_callback = (callback || callback_block)
end