diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/DefaultStompSession.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/DefaultStompSession.java index 711607801ea..c8e29357ca0 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/DefaultStompSession.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/DefaultStompSession.java @@ -456,8 +456,8 @@ public class DefaultStompSession implements ConnectionHandlingStompSession { logger.debug("Connection closed session id=" + this.sessionId); } if (!this.closing) { - handleFailure(new ConnectionLostException("Connection closed")); resetConnection(); + handleFailure(new ConnectionLostException("Connection closed")); } } @@ -647,8 +647,8 @@ public class DefaultStompSession implements ConnectionHandlingStompSession { if (logger.isDebugEnabled()) { logger.debug(error); } - handleFailure(new IllegalStateException(error)); resetConnection(); + handleFailure(new IllegalStateException(error)); } }