JetStreamClientLike
Defined in: src/io/broker/JetStreamActor.ts:577
Properties
Section titled “Properties”consumers
Section titled “consumers”
readonlyconsumers:object
Defined in: src/io/broker/JetStreamActor.ts:592
Pull-consumer accessor (#62). Returns a handle that exposes
fetch for batched on-demand delivery — see the nats.js
consumers.get(stream, durable) API.
get(
stream,durable):Promise<PullConsumerLike>
Parameters
Section titled “Parameters”stream
Section titled “stream”string
durable
Section titled “durable”string
Returns
Section titled “Returns”Promise<PullConsumerLike>
Methods
Section titled “Methods”publish()
Section titled “publish()”publish(
subject,payload,opts?):Promise<unknown>
Defined in: src/io/broker/JetStreamActor.ts:578
Parameters
Section titled “Parameters”subject
Section titled “subject”string
payload
Section titled “payload”Uint8Array
expect?
Section titled “expect?”{ lastSequence?: number; }
expect.lastSequence?
Section titled “expect.lastSequence?”number
headers?
Section titled “headers?”Readonly<Record<string, string>>
msgID?
Section titled “msgID?”string
Returns
Section titled “Returns”Promise<unknown>
subscribe()
Section titled “subscribe()”subscribe(
subject,opts):Promise<JetStreamSubscriptionLike>
Defined in: src/io/broker/JetStreamActor.ts:583
Parameters
Section titled “Parameters”subject
Section titled “subject”string
consumer
Section titled “consumer”string
stream
Section titled “stream”string
Returns
Section titled “Returns”Promise<JetStreamSubscriptionLike>