Fix wrong test assertion

jeanouii · jeanouii · commit 4ffe8f7102b2 · 2026-01-08T17:38:37.000+01:00
diff --git a/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverterTest.java b/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverterTest.java
@@ -129,7 +129,7 @@ public void run() {
         executorService.awaitTermination(10, TimeUnit.SECONDS);
 
         ArgumentCaptor<RemoveInfo> removeInfo = ArgumentCaptor.forClass(RemoveInfo.class);
-        Mockito.verify(transport, times(4)).sendToActiveMQ(removeInfo.capture());
+        Mockito.verify(transport, times(1)).sendToActiveMQ(removeInfo.capture());
 
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ public void run() {`
`129`	`129`	`executorService.awaitTermination(10, TimeUnit.SECONDS);`
`130`	`130`
`131`	`131`	`ArgumentCaptor<RemoveInfo> removeInfo = ArgumentCaptor.forClass(RemoveInfo.class);`
`132`		`- Mockito.verify(transport, times(4)).sendToActiveMQ(removeInfo.capture());`
	`132`	`+ Mockito.verify(transport, times(1)).sendToActiveMQ(removeInfo.capture());`
`133`	`133`
`134`	`134`	`}`
`135`	`135`	`}`