diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java index 1661ab2130..72f215480d 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java @@ -1240,9 +1240,6 @@ public class ServerSessionImpl implements ServerSession, FailureListener { if (closed) return; - if (failed) { - - } context.executeOnCompletion(new IOCallback() { @Override public void onError(int errorCode, String errorMessage) {