Class: NATS::JetStream::PubAck

Inherits:

Struct

• Object
• Struct
• NATS::JetStream::PubAck

Defined in:

lib/nats/io/jetstream.rb

Overview

PubAck is the API response from a successfully published message.

Instance Attribute Summary

• #stream ⇒ String readonly

  Name of the stream that processed the published message.

Instance Method Summary

• #domain(value) ⇒ String

  JetStream Domain that processed the ack response.

• #duplicate(value) ⇒ Boolean

  Indicates whether the published message is a duplicate.

• #seq(value) ⇒ Fixnum

  Sequence of the message in the stream.

Instance Attribute Details

#stream ⇒ String (readonly)

Returns Name of the stream that processed the published message.

Returns:

• (String) —

  Name of the stream that processed the published message.

# File 'lib/nats/io/jetstream.rb', line 71

PubAck = Struct.new(:stream, :seq, :duplicate, :domain, keyword_init: true)

Instance Method Details

#domain=(value) ⇒ String

Returns JetStream Domain that processed the ack response.

Returns:

• (String) —

  JetStream Domain that processed the ack response.

# File 'lib/nats/io/jetstream.rb', line 71

PubAck = Struct.new(:stream, :seq, :duplicate, :domain, keyword_init: true)

#duplicate=(value) ⇒ Boolean

Returns Indicates whether the published message is a duplicate.

Returns:

• (Boolean) —

  Indicates whether the published message is a duplicate.

# File 'lib/nats/io/jetstream.rb', line 71

PubAck = Struct.new(:stream, :seq, :duplicate, :domain, keyword_init: true)

#seq=(value) ⇒ Fixnum

Returns Sequence of the message in the stream.

Returns:

• (Fixnum) —

  Sequence of the message in the stream.

# File 'lib/nats/io/jetstream.rb', line 71

PubAck = Struct.new(:stream, :seq, :duplicate, :domain, keyword_init: true)