Class: OMQ::QoS::DeadLetter

Inherits:

Data

• Object
• Data
• OMQ::QoS::DeadLetter

Defined in:

lib/omq/qos.rb

Overview

Data outcome pushed through #send's Promise when a message cannot be delivered under the requested guarantee.

Instance Attribute Summary

• #error ⇒ NackInfo^? readonly

  NACK details at QoS 3; nil at QoS 2.

• #parts ⇒ Array<String> readonly

  The original message frames.

• #peer_info ⇒ Protocol::ZMTP::PeerInfo^? readonly

  Peer it was pinned to, if any.

• #reason ⇒ Symbol readonly

  :peer_timeout, :terminal_nack, :retry_exhausted, :socket_closed.

Instance Attribute Details

#error ⇒ NackInfo^? (readonly)

Returns NACK details at QoS 3; nil at QoS 2.

Returns:

• (NackInfo, nil) —

  NACK details at QoS 3; nil at QoS 2

# File 'lib/omq/qos.rb', line 77

DeadLetter = Data.define(:parts, :reason, :peer_info, :error)

#parts ⇒ Array<String> (readonly)

Returns the original message frames.

Returns:

• (Array<String>) —

  the original message frames

# File 'lib/omq/qos.rb', line 77

DeadLetter = Data.define(:parts, :reason, :peer_info, :error)

#peer_info ⇒ Protocol::ZMTP::PeerInfo^? (readonly)

Returns peer it was pinned to, if any.

Returns:

• (Protocol::ZMTP::PeerInfo, nil) —

  peer it was pinned to, if any

# File 'lib/omq/qos.rb', line 77

DeadLetter = Data.define(:parts, :reason, :peer_info, :error)

#reason ⇒ Symbol (readonly)

Returns :peer_timeout, :terminal_nack, :retry_exhausted, :socket_closed.

Returns:

• (Symbol) —

  :peer_timeout, :terminal_nack, :retry_exhausted, :socket_closed

# File 'lib/omq/qos.rb', line 77

DeadLetter = Data.define(:parts, :reason, :peer_info, :error)