struct

Alumna::Nats::JetStream::Message

Inherits Struct < Value < Object

Inbound JetStream message. body is a view; copy it if you keep it after the handler returns. 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, body : Bytes, stream : String, consumer : String, delivered_count : Int64, reply_to : String)
Source

Instance methods

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