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/heartbeat.rb,
lib/eventhub/processor.rb,
lib/eventhub/configuration.rb,
lib/eventhub/argument_parser.rb
Defined Under Namespace
Modules: Helper Classes: ArgumentParser, BaseException, Configuration, Heartbeat, Message, MessageProcessor, NoDeadletterException, Processor, Statistics
Constant Summary collapse
- VERSION =
'0.4.10'
- 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 =
301
- STATUS_INVALID =
Set and used by the dispatcher only. 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 =
To be set to indicate invalid message (not json, invalid Event Hub Message). Dispatcher will publish message to the invalid queue.
500
Class Method Summary collapse
Class Method Details
.logger ⇒ Object
29 30 31 32 33 34 35 |
# File 'lib/eventhub-processor.rb', line 29 def self.logger unless @logger @logger = ::EventHub::Components::MultiLogger.new @logger.add_device(Logger.new(STDOUT)) end @logger end |