diff --git a/examples/jetstream/ack-ack/java/Main.java b/examples/jetstream/ack-ack/java/Main.java index ddfa8081..1b20fd13 100644 --- a/examples/jetstream/ack-ack/java/Main.java +++ b/examples/jetstream/ack-ack/java/Main.java @@ -36,7 +36,7 @@ public static void main(String[] args) { js.publish("verifyAckSubject", "B".getBytes()); // Consume a message with 2 different consumers - // The first consumer will ack without confirmation + // The first consumer will (regular) ack without confirmation // The second consumer will ackSync which confirms that ack was handled. StreamContext sc = nc.getStreamContext("verifyAckStream"); ConsumerContext cc1 = sc.createOrUpdateConsumer(ConsumerConfiguration.builder().filterSubject("verifyAckSubject").build()); diff --git a/examples/jetstream/ack-ack/java/output.cast b/examples/jetstream/ack-ack/java/output.cast index c87e5a9e..5d6fe19b 100644 --- a/examples/jetstream/ack-ack/java/output.cast +++ b/examples/jetstream/ack-ack/java/output.cast @@ -1,5 +1,4 @@ {"version": 2, "width": 0, "height": 0, "timestamp": 1718718084, "env": {"SHELL": null, "TERM": null}, "title": "NATS by Example: jetstream/ack-ack/java"} -[2.175888, "o", "\u001b[33mWARN\u001b[0m[0000] /tmp/4177257857/docker-compose.yaml: `version` is obsolete \r\n"] [2.975389, "o", "Consumer 1\r\n Start\r\n # pending messages: 2\r\n # messages with ack pending: 0\r\n"] [2.986982, "o", " After received but before ack\r\n # pending messages: 1\r\n # messages with ack pending: 1\r\n"] [3.089129, "o", " After ack\r\n # pending messages: 1\r\n # messages with ack pending: 0\r\n"] diff --git a/examples/jetstream/ack-ack/java/output.txt b/examples/jetstream/ack-ack/java/output.txt index 167ee042..878ea538 100644 --- a/examples/jetstream/ack-ack/java/output.txt +++ b/examples/jetstream/ack-ack/java/output.txt @@ -1,4 +1,3 @@ -WARN[0000] /tmp/4177257857/docker-compose.yaml: `version` is obsolete Consumer 1 Start # pending messages: 2