fixed rate limit comparison bug (#951)

nats-io · Aug 11, 2023 · 19aa491 · 19aa491
1 parent f362bc7
commit 19aa491
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/nats/client/impl/NatsJetStream.java b/src/main/java/io/nats/client/impl/NatsJetStream.java
@@ -468,7 +468,7 @@ public List<String> getChanges(ConsumerConfiguration serverCc) {
             if (memStorage != null && memStorage != serverCcc.isMemStorage()) { changes.add("memStorage"); };
 
             if (startSeq != null && !startSeq.equals(serverCcc.getStartSequence())) { changes.add("startSequence"); };
-            if (rateLimit != null && !rateLimit.equals(serverCcc.getStartSequence())) { changes.add("rateLimit"); };
+            if (rateLimit != null && !rateLimit.equals(serverCcc.getRateLimit())) { changes.add("rateLimit"); };
 
             if (maxDeliver != null && maxDeliver != serverCcc.getMaxDeliver()) { changes.add("maxDeliver"); };
             if (maxAckPending != null && maxAckPending != serverCcc.getMaxAckPending()) { changes.add("maxAckPending"); };