Class: JetstreamBridge::MessageProcessor::ActionResult

Inherits:

Struct

• Object
• Struct
• JetstreamBridge::MessageProcessor::ActionResult

Defined in:

lib/jetstream_bridge/consumer/message_processor.rb

Overview

Result of processing a single message.

Instance Attribute Summary

• #action ⇒ Symbol readonly

  :ack or :nak.

• #ctx ⇒ MessageContext readonly

  Per-message metadata.

• #delay ⇒ Integer^? readonly

  NAK delay in seconds.

• #error ⇒ Exception^? readonly

  Error if processing failed.

Instance Attribute Details

#action ⇒ Symbol (readonly)

Returns :ack or :nak.

Returns:

• (Symbol) —

  :ack or :nak

# File 'lib/jetstream_bridge/consumer/message_processor.rb', line 94

ActionResult = Struct.new(:action, :ctx, :error, :delay, keyword_init: true)

#ctx ⇒ MessageContext (readonly)

Returns Per-message metadata.

Returns:

• (MessageContext) —

  Per-message metadata

# File 'lib/jetstream_bridge/consumer/message_processor.rb', line 94

ActionResult = Struct.new(:action, :ctx, :error, :delay, keyword_init: true)

#delay ⇒ Integer^? (readonly)

Returns NAK delay in seconds.

Returns:

• (Integer, nil) —

  NAK delay in seconds

# File 'lib/jetstream_bridge/consumer/message_processor.rb', line 94

ActionResult = Struct.new(:action, :ctx, :error, :delay, keyword_init: true)

#error ⇒ Exception^? (readonly)

Returns Error if processing failed.

Returns:

• (Exception, nil) —

  Error if processing failed

# File 'lib/jetstream_bridge/consumer/message_processor.rb', line 94

ActionResult = Struct.new(:action, :ctx, :error, :delay, keyword_init: true)