Skip to content

Commit 8e67446

Browse files
author
Steve Powell
committed
In case flush() throws an exception.
1 parent 87259f8 commit 8e67446

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/com/rabbitmq/client/impl/SocketFrameHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ public void flush() throws IOException {
144144

145145
public void close() {
146146
try { _socket.setSoLinger(true, SOCKET_CLOSING_TIMEOUT); } catch (Exception _) {}
147-
try { flush(); _socket.close(); } catch (Exception _) {}
147+
try { flush(); } catch (Exception _) {}
148+
try { _socket.close(); } catch (Exception _) {}
148149
}
149150
}

0 commit comments

Comments
 (0)