Check both connection and connected flag

Issue: SPR-14703
This commit is contained in:
Rossen Stoyanchev
2016-09-14 17:19:49 -04:00
parent be99603f1b
commit 07d5f8b123

View File

@@ -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 " +