struct

Alumna::Nats::JetStream::Message

Inherits Struct < Value < Object

Inbound JetStream message. payload is the server text. It stays valid while you keep this value. body is a byte view of payload. Copy body if you keep the bytes and drop this value. Pass the same value to ack or nack. The handler does not ack.

Constructors

from_driver(raw : NATS::JetStream::Message) : self
Source
new(subject : String, payload : String, stream : String, consumer : String, delivered_count : Int64, reply_to : String)
Source

Instance methods

body
Source
consumer
Source
delivered_count
Source
payload
Source
reply_to
Source
stream
Source
subject
Source