Exception: JetstreamBridge::ConsumerError

Inherits:
Error
  • Object
show all
Defined in:
lib/jetstream_bridge/errors.rb

Overview

Raised when message consumption encounters an error.

Direct Known Subclasses

HandlerError, InboxError

Instance Attribute Summary collapse

Attributes inherited from Error

#context

Instance Method Summary collapse

Constructor Details

#initialize(message = nil, event_id: nil, deliveries: nil, context: {}) ⇒ ConsumerError

Returns a new instance of ConsumerError.

Parameters:

  • (defaults to: nil)

    Human-readable error message

  • (defaults to: nil)

    The event ID being consumed

  • (defaults to: nil)

    Delivery attempt count

  • (defaults to: {})

    Additional diagnostic context



96
97
98
99
100
 
# File 'lib/jetstream_bridge/errors.rb', line 96

def initialize(message = nil, event_id: nil, deliveries: nil, context: {})
  @event_id = event_id
  @deliveries = deliveries
  super(message, context: context.merge(event_id: event_id, deliveries: deliveries).compact)
end

Instance Attribute Details

#deliveries ⇒ Integer? (readonly)

Returns Number of delivery attempts so far.

Returns:

  • Number of delivery attempts so far



90
91
92
 
# File 'lib/jetstream_bridge/errors.rb', line 90

def deliveries
  @deliveries
end

#event_id ⇒ String? (readonly)

Returns Event ID being processed.

Returns:

  • Event ID being processed



88
89
90
 
# File 'lib/jetstream_bridge/errors.rb', line 88

def event_id
  @event_id
end