Module: EventHub

Defined in:
lib/eventhub/helper.rb,
lib/eventhub/message.rb,
lib/eventhub/version.rb,
lib/eventhub/constant.rb,
lib/eventhub-processor.rb,
lib/eventhub/processor.rb,
lib/eventhub/multi_logger.rb,
lib/eventhub/configuration.rb,
lib/eventhub/argument_parser.rb

Defined Under Namespace

Modules: Helper Classes: ArgumentParser, Configuration, Message, MultiLogger, Processor

Constant Summary collapse

VERSION = 
"0.2.3"
EH_X_INBOUND = 
'event_hub.inbound'
STATUS_INITIAL =

To be set when dispatcher needs to dispatch to first process step.

0
STATUS_SUCCESS =

To be set to indicate successful processed message. Dispatcher will routes message to the next step.

200
STATUS_RETRY =

To be set to trigger retry cycle controlled by the dispatcher

300
STATUS_RETRY_PENDING =

Set and used by the dispatcher only.

301
STATUS_INVALID =

Set before putting the message into a retry queue. Once message has been retried it will sent do the same step with status.code = STATUS_SUCCESS

400
STATUS_DEADLETTER =

Dispatcher will publish message to the invalid queue.

500

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



23
24
25
26
27
28
29
 
# File 'lib/eventhub-processor.rb', line 23

def self.logger
  unless @logger
    @logger = MultiLogger.new
    @logger.add_device(Logger.new(STDOUT))
  end
  @logger
end