diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java index 22b3aeba0a4..1c1f0d4ce44 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java @@ -648,6 +648,8 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler } finally { try { + // Prevent clearConnection() from trying to close + this.tcpConnection = null; clearConnection(); } catch (Throwable t) {