Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Too many WriteToClosedSessionException when upgrade to quickfixj-2.3.2 #928

Open
leonchen83 opened this issue Jan 14, 2025 · 9 comments
Open

Too many WriteToClosedSessionException when upgrade to quickfixj-2.3.2 #928

leonchen83 opened this issue Jan 14, 2025 · 9 comments
Labels
bug

Comments

@leonchen83
Copy link
Contributor

leonchen83 commented Jan 14, 2025 •
edited
Loading

Describe the bug
A clear and concise description of what the bug is.

org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)

To Reproduce
Steps to reproduce the behavior.
Or even better, a unit test or reproducer.

Expected behavior
A clear and concise description of what you expected to happen.

No Exception

system information:

  • OS: Linux 4.18.0-193.el8.x86_64 github test issue #1 SMP Fri May 8 10:59:10 UTC 2020 x86_64 x86_64 x86_64 GNU/Linux
  • Java version Java21
  • QFJ Version 2.3.2

Additional context
Add any other context about the problem here.

Could this issue be related to the changes introduced in #543?
@leonchen83 leonchen83 added the bug label Jan 14, 2025
@chrjohn
Copy link
Member

chrjohn commented Jan 14, 2025

When exactly does this occur?

@leonchen83
Copy link
Contributor Author

In our testing environment, we need to connect to a test LP. If the connection attempt receives no response, this exception occurs every time we reconnect. This issue did not exist in the previous quickfixj version.

@chrjohn
Copy link
Member

chrjohn commented Jan 14, 2025

Could you show some log output where the connection attempts are shown in conjunction with the exception?

@leonchen83
Copy link
Contributor Author 

250114.121008.706: Initiated logon request
250114.121019.705: Disconnecting: Timed out waiting for logon response
250114.121019.706: Already disconnected: Socket exception (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteRejectedException: closing
250114.121020.331: MINA session created: local=/172.30.1.171:50766, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=fixdemo.fxcorporate.com/204.8.241.23:9004
250114.121020.706: Initiated logon request
250114.121031.705: Disconnecting: Timed out waiting for logon response
250114.121031.706: Already disconnected: Socket exception (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteRejectedException: closing
250114.121032.867: MINA session created: local=/172.30.1.171:50782, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=fixdemo.fxcorporate.com/204.8.241.23:9004
250114.121032.871: Initiated logon request
250114.121043.705: Disconnecting: Timed out waiting for logon response
250114.121043.706: Already disconnected: Socket exception (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteRejectedException: closing
250114.121044.207: MINA session created: local=/172.30.1.171:50792, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=fixdemo.fxcorporate.com/204.8.241.23:9004
250114.121044.706: Initiated logon request
250114.121055.705: Disconnecting: Timed out waiting for logon response
250114.121055.706: Already disconnected: Socket exception (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteRejectedException: closing
250114.121056.573: MINA session created: local=/172.30.1.171:50804, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=fixdemo.fxcorporate.com/204.8.241.23:9004
250114.121056.706: Initiated logon request
250114.121107.705: Disconnecting: Timed out waiting for logon response
250114.121107.706: Already disconnected: Socket exception (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteRejectedException: closing
250114.121109.098: MINA session created: local=/172.30.1.171:50818, class org.apache.mina.transport.socket.nio.NioSocketSession, remote=fixdemo.fxcorporate.com/204.8.241.23:9004

@chrjohn
Copy link
Member

chrjohn commented Jan 14, 2025

In the log above I see WriteRejectedException. Where does WriteToClosedSessionException occur?
Thanks

@leonchen83
Copy link
Contributor Author

leonchen83 commented Jan 14, 2025 •
edited
Loading

We have actually split the log into two files. One file contains the WriteToClosedSessionException, and the other contains the WriteRejectedException. The current problem is that whenever a WriteRejectedException occurs, a WriteToClosedSessionException also appears

the other part of log file is following

org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:13:41.803 ERROR[NioProcessor-2675 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:13:42.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:13:42.780 ERROR[NioProcessor-2685 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:13:53.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:13:53.779 ERROR[NioProcessor-2705 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:13:53.803 ERROR[NioProcessor-2695 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:04.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:14:04.779 ERROR[NioProcessor-2715 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:05.803 ERROR[NioProcessor-2725 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:15.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:14:15.779 ERROR[NioProcessor-2735 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:16.090 INFO [system.scheduler-1 AbstractCluster.pulse:292][system.service.cluster]ping server@1, services: 34, elapsed time: 0 ms
25-01-13 21:14:16.092 INFO [system.scheduler-1 AbstractCluster.pulse:292][system.service.cluster]ping trigger@69, services: 2, elapsed time: 1 ms
25-01-13 21:14:16.868 ERROR[NioProcessor-2745 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:27.780 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:14:27.780 ERROR[NioProcessor-2746 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:28.803 ERROR[NioProcessor-2756 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:38.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:14:38.779 ERROR[NioProcessor-2766 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:40.803 ERROR[NioProcessor-2776 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:49.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:14:49.779 ERROR[NioProcessor-2786 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:14:51.803 ERROR[NioProcessor-2796 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:00.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:15:00.780 ERROR[NioProcessor-2806 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:03.803 ERROR[NioProcessor-2816 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:12.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:15:12.779 ERROR[NioProcessor-2826 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:15.803 ERROR[NioProcessor-2827 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:16.090 INFO [system.scheduler-1 AbstractCluster.pulse:292][system.service.cluster]ping server@1, services: 34, elapsed time: 1 ms
25-01-13 21:15:16.091 INFO [system.scheduler-1 AbstractCluster.pulse:292][system.service.cluster]ping trigger@69, services: 2, elapsed time: 0 ms
25-01-13 21:15:24.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:15:24.780 ERROR[NioProcessor-2837 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:27.803 ERROR[NioProcessor-2847 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:36.779 INFO [pipeline.puller-1 UnsubscribeQuotesAction.doProcess:73][hedging.action.unsubscribe.quotes]start to unsubscribe, session: 65592
25-01-13 21:15:36.779 ERROR[NioProcessor-2857 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo.fxcorporate.com/204.8.241.23:9004): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
25-01-13 21:15:39.803 ERROR[NioProcessor-2867 InitiatorIoHandler.exceptionCaught:89]Socket (fixdemo5.fxcorporate.com/204.8.241.132:80): org.apache.mina.core.write.WriteToClosedSessionException
org.apache.mina.core.write.WriteToClosedSessionException: null
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.clearWriteRequestQueue(AbstractPollingIoProcessor.java:1192)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeNow(AbstractPollingIoProcessor.java:1153)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.removeSessions(AbstractPollingIoProcessor.java:864)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:694)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)

@chrjohn
Copy link
Member

chrjohn commented Jan 14, 2025

Are you trying to send messages before the logon is established? I am wondering which messages are trying to be written. Could be the sent Logon but on the other hand the Logon should not get sent when the session cannot be established.

@leonchen83
Copy link
Contributor Author

We only sent the logon message after the connection was established, without any other messages.

@chrjohn
Copy link
Member

chrjohn commented Jan 27, 2025

I checked this and this seems to be caused by internal changes in MINA 2.2.x when destroying the connector. It cannot be caused by closeOnFlush() since that line of code is not reached when that exception is caught in AbstractIoHandler.exceptionCaught().
Question: are you using TLS? I assume it could be TLS handshake messages that are still trying to be written.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@leonchen83 @chrjohn