module EventHub

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

EventHub module

Constants

EH_X_INBOUND
STATUS_CODE_TRANSLATION
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/logger.rb, line 3
def self.logger
  unless @logger
    @logger = ::EventHub::Components::MultiLogger.new
    @logger.add_device(Logger.new($stdout))
    @logger.add_device(
      EventHub::Components::Logger.logstash(Configuration.name,
        Configuration.environment)
    )
  end
  @logger
end