diff --git a/jetstream/consumer.ts b/jetstream/consumer.ts index 50bfae46..8ccf42f0 100644 --- a/jetstream/consumer.ts +++ b/jetstream/consumer.ts @@ -250,7 +250,7 @@ export class PullConsumerMessagesImpl extends QueuedIteratorImpl this.refilling = refilling; this.stack = new Error().stack!.split("\n").slice(1).join("\n"); this.timeout = null; - this.inbox = createInbox(); + this.inbox = createInbox(c.api.nc.options.inboxPrefix); this.listeners = []; const {