Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix connection race condition in MQTT test

Browse Source 
It looks like `isConnected` flag in the MQTT Client is reset when we already
have subscribed
This commit is contained in:
abilan
2023-02-22 14:16:16 -05:00
parent fe9b59ea01
commit 3f99424d93
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/ResubscribeAfterAutomaticReconnectTests.java
View File

@@ -40,6 +40,7 @@ import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
import static org.assertj.core.api.Assertions.assertThat;
import static org.awaitility.Awaitility.await;
/**
* @author Artem Bilan
@@ -81,7 +82,7 @@ public class ResubscribeAfterAutomaticReconnectTests implements MosquittoContain
assertThat(this.config.subscribeSecondLatch.await(10, TimeUnit.SECONDS)).isTrue();
this.mqttOutFlowInput.send(testMessage);
await().untilAsserted(() -> this.mqttOutFlowInput.send(testMessage));
assertThat(this.fromMqttChannel.receive(10_000)).isNotNull();
// Re-subscription on channel adapter restart with cleanStart