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

Fix StompMHWebSocketIntTests for reconnect events

Browse Source 
https://build.spring.io/browse/INT-MASTERSPRING40-740
This commit is contained in:
Artem Bilan
2019-06-17 13:02:24 -04:00
parent a77dac5347
commit 153a748166
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-integration-stomp/src/test/java/org/springframework/integration/stomp/outbound/StompMessageHandlerWebSocketIntegrationTests.java
View File

@@ -44,6 +44,7 @@ import org.springframework.integration.config.EnableIntegration;
import org.springframework.integration.event.inbound.ApplicationEventListeningMessageProducer;
import org.springframework.integration.stomp.StompSessionManager;
import org.springframework.integration.stomp.WebSocketStompSessionManager;
import org.springframework.integration.stomp.event.StompConnectionFailedEvent;
import org.springframework.integration.stomp.event.StompExceptionEvent;
import org.springframework.integration.stomp.event.StompIntegrationEvent;
import org.springframework.integration.stomp.event.StompReceiptEvent;
@@ -140,6 +141,14 @@ public class StompMessageHandlerWebSocketIntegrationTests {
Message<?> failedMessage = messageDeliveryException.getFailedMessage();
assertThat((String) failedMessage.getPayload()).contains("preSend intentional Exception");
receive = this.stompEvents.receive(10000);
assertThat(receive).isNotNull();
assertThat(receive.getPayload()).isInstanceOf(StompConnectionFailedEvent.class);
receive = this.stompEvents.receive(10000);
assertThat(receive).isNotNull();
assertThat(receive.getPayload()).isInstanceOf(StompSessionConnectedEvent.class);
receive = this.stompEvents.receive(10000);
assertThat(receive).isNotNull();
assertThat(receive.getPayload()).isInstanceOf(StompReceiptEvent.class);