Class: EmPipelines::Pipeline::TerminatorStage

Inherits:

Object

Object
EmPipelines::Pipeline::TerminatorStage

show all

Defined in:: lib/empipelines/pipeline.rb

Class Method Summary collapse

.notify(message, ignored = {}) ⇒ Object

Class Method Details

.notify(message, ignored = {}) ⇒ `Object`



4
5
6

# File 'lib/empipelines/pipeline.rb', line 4

def self.notify(message, ignored = {})
  message.consumed!
end