module EventHub

Constants

EH_X_INBOUND
STATUS_DEADLETTER
STATUS_INITIAL
STATUS_INVALID

Once message has been retried it will sent do the same step with status.code = STATUS_SUCCESS

STATUS_RETRY
STATUS_RETRY_PENDING
STATUS_SCHEDULE

status.code = STATUS_DEADLETTER due to the RabbitMQ deadletter exchange mechanism.

STATUS_SCHEDULE_PENDING
STATUS_SCHEDULE_RETRY
STATUS_SUCCESS
VERSION

Public Class Methods

logger() click to toggle source
# File lib/eventhub-processor.rb, line 30
def self.logger
      unless @logger
              @logger = ::EventHub::Components::MultiLogger.new
    @logger.add_device(Logger.new(STDOUT))
      end
      @logger
end