Message Info always use last value in the headers. (#1099)

nats-io · Mar 18, 2024 · c9512c6 · c9512c6
1 parent 9d5fb0a
commit c9512c6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/io/nats/client/api/MessageInfo.java b/src/main/java/io/nats/client/api/MessageInfo.java
@@ -67,10 +67,10 @@ public MessageInfo(Message msg, String streamName, boolean direct) {
             Headers msgHeaders = msg.getHeaders();
             this.subject = msgHeaders.getLast(NATS_SUBJECT);
             this.data = msg.getData();
-            seq = Long.parseLong(msgHeaders.getFirst(NATS_SEQUENCE));
-            time = DateTimeUtils.parseDateTime(msgHeaders.getFirst(NATS_TIMESTAMP));
-            stream = msgHeaders.getFirst(NATS_STREAM);
-            String temp = msgHeaders.getFirst(NATS_LAST_SEQUENCE);
+            seq = Long.parseLong(msgHeaders.getLast(NATS_SEQUENCE));
+            time = DateTimeUtils.parseDateTime(msgHeaders.getLast(NATS_TIMESTAMP));
+            stream = msgHeaders.getLast(NATS_STREAM);
+            String temp = msgHeaders.getLast(NATS_LAST_SEQUENCE);
             if (temp == null) {
                 lastSeq = -1;
             }

diff --git a/src/main/java/io/nats/client/impl/NatsStreamContext.java b/src/main/java/io/nats/client/impl/NatsStreamContext.java
@@ -27,7 +27,7 @@ class NatsStreamContext implements StreamContext {
     final NatsJetStream js;
     final NatsJetStreamManagement jsm;
 
-    // for when this is contructed from the NatsJetStream itself
+    // for when this is constructed from the NatsJetStream itself
     NatsStreamContext(String streamName, NatsJetStream js, NatsConnection connection, JetStreamOptions jsOptions) throws IOException, JetStreamApiException {
         this.streamName = streamName;
         this.js = js == null ? new NatsJetStream(connection, jsOptions) : js;