Remove duplicate reconnect event (#1151)

nats-io · May 20, 2024 · f090bed · f090bed
1 parent 87b0abc
commit f090bed
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -438,8 +438,6 @@ else if (first.equals(cur)) {
 
         processConnectionEvent(Events.RESUBSCRIBED);
 
-        processConnectionEvent(Events.RECONNECTED);
-
         // When the flush returns we are done sending internal messages,
         // so we can switch to the non-reconnect queue
         this.writer.setReconnectMode(false);

diff --git a/src/test/java/io/nats/client/impl/ConnectionListenerTests.java b/src/test/java/io/nats/client/impl/ConnectionListenerTests.java
@@ -96,7 +96,7 @@ public void testDisconnectReconnectCount() throws Exception {
 
         try (NatsTestServer ts = new NatsTestServer(port, false)) {
             standardConnectionWait(nc);
-            assertEquals(2, listener.getEventCount(Events.RECONNECTED));
+            assertEquals(1, listener.getEventCount(Events.RECONNECTED));
             assertEquals(ts.getURI(), nc.getConnectedUrl());
             standardCloseConnection(nc);
         }