Skip to content

Commit

Permalink
[DENO] Ack Ack
Browse files Browse the repository at this point in the history
  • Loading branch information
scottf committed Jul 15, 2024
1 parent 07f67b9 commit b59a360
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions examples/jetstream/ack-ack/deno/main.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ import {StorageType} from "../../jetstream/jsapi_types.ts";
const servers = Deno.env.get("NATS_URL") || "nats://localhost:4222";

// Create a client connection to an available NATS server.

const nc = await connect({ servers });

// create a stream with a random name with some messages and a consumer
Expand All @@ -31,7 +30,7 @@ try {
}
}

const si = await jsm.streams.add({
await jsm.streams.add({
name: stream,
subjects: [subject],
storage: StorageType.Memory,
Expand Down Expand Up @@ -76,7 +75,6 @@ try {
console.log(`consume failed: ${err.message}`);
}


// Consumer 2 will use ackAck()
let ci2 = await jsm.consumers.add(stream, {
name: "consumer2",
Expand Down

0 comments on commit b59a360

Please sign in to comment.