Browse Source

Check both connection and connected flag

Issue: SPR-14703
pull/1195/head
Rossen Stoyanchev 9 years ago
parent
commit
114b2b63b1
  1. 2
      spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java

2
spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java

@ -768,7 +768,7 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler @@ -768,7 +768,7 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler
public ListenableFuture<Void> forward(final Message<?> message, final StompHeaderAccessor accessor) {
TcpConnection<byte[]> conn = this.tcpConnection;
if (!this.isStompConnected) {
if (!this.isStompConnected || conn == null) {
if (this.isRemoteClientSession) {
if (logger.isDebugEnabled()) {
logger.debug("TCP connection closed already, ignoring " +

Loading…
Cancel
Save