[Quickfixj-users] Session Timer cancellation query

[philip <ph...@wh...>]

Hi folks,

I've been investigating an issue where our process is stopped on the edge of a session boundary.

In this scenario we get the following logging:

17:30:01 INFO (SessionConnector.java:265) [adminthread] - SessionTimer canceled
...
17:30:01 ERROR (InternalLayer.java:186) [QFJ Timer] - An error occurred while writing ....
...
at InternalLayer.reset(InternalLayer.java:658)
...
at quickfix.SessionState.reset(SessionState.java:382)
at quickfix.Session.resetState(Session.java:2516)
at quickfix.Session.reset(Session.java:823)
at quickfix.Session.next(Session.java:1795)
at quickfix.mina.SessionConnector$SessionTimerTask.run(SessionConnector.java:278)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)


As you can see from the abbreviated stack trace, the Session reset appears (subject to logging) to be passed to our internal layer after the session timer is cancelled.

Looking at the code for Session Connector

   protected void stopSessionTimer() {
       if (sessionTimerFuture != null) {
           if (sessionTimerFuture.cancel(true))
               log.info("SessionTimer canceled");
       }
   }

we are cancelling the timer. But does this actually prevent the current task from executing. The combination of DelegatingTask and BlockingSupportTask make it difficult to parse.

Has anyone else seen similar issues?