We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5edc613 commit d22daebCopy full SHA for d22daeb
quickfixj-core/src/main/java/quickfix/mina/AbstractIoHandler.java
@@ -110,12 +110,12 @@ public void sessionClosed(IoSession ioSession) throws Exception {
110
Session quickFixSession = findQFSession(ioSession);
111
if (quickFixSession != null) {
112
eventHandlingStrategy.onMessage(quickFixSession, EventHandlingStrategy.END_OF_STREAM);
113
- ioSession.removeAttribute(SessionConnector.QF_SESSION);
114
}
115
- ioSession.closeNow();
116
} catch (Exception e) {
117
118
throw e;
+ } finally {
+ ioSession.removeAttribute(SessionConnector.QF_SESSION);
+ ioSession.closeNow();
119
120
121
0 commit comments