diff --git a/smack-tcp/src/main/java/org/jivesoftware/smack/tcp/XMPPTCPConnection.java b/smack-tcp/src/main/java/org/jivesoftware/smack/tcp/XMPPTCPConnection.java index 669130420..558bacdf0 100644 --- a/smack-tcp/src/main/java/org/jivesoftware/smack/tcp/XMPPTCPConnection.java +++ b/smack-tcp/src/main/java/org/jivesoftware/smack/tcp/XMPPTCPConnection.java @@ -1272,7 +1272,6 @@ public class XMPPTCPConnection extends AbstractXMPPConnection { } private void writePackets() { - Exception writerException = null; try { // Write out packets from the queue. while (!done()) { @@ -1382,15 +1381,11 @@ public class XMPPTCPConnection extends AbstractXMPPConnection { // The exception can be ignored if the the connection is 'done' // or if the it was caused because the socket got closed if (!(done() || queue.isShutdown())) { - writerException = e; + notifyConnectionError(e); } else { LOGGER.log(Level.FINE, "Ignoring Exception in writePackets()", e); } } - // Delay notifyConnectionError after shutdownDone has been reported in the finally block. - if (writerException != null) { - notifyConnectionError(writerException); - } } private void drainWriterQueueToUnacknowledgedStanzas() {