struct

Alumna::Nats::JetStream::Consumer

Durable push consumer. deliver_subject is nil for a pull consumer (not in this product).

Constructors

from_driver(raw : NATS::JetStream::Consumer) : self

new(stream : String, name : String, deliver_subject : String | Nil, deliver_group : String | Nil, filter_subject : String | Nil, num_pending : Int64, num_ack_pending : Int64)

Source

Instance methods

deliver_group

deliver_subject

filter_subject

name

num_ack_pending

num_pending

stream