[AMQ-2883] EOFException if stomp+nio after ActiveMQ has sent the first bytes message

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.4.0
• Fix Version/s: 5.4.1
• Component/s: Transport

Environment

Windows Vista

• Assignee: Timothy A. Bish
• Reporter: Michael Justin
• Created: 29/Aug/10 11:21
• Updated: 01/Sep/10 14:25
• Resolved: 30/Aug/10 15:48

Description

Starting broker with C:\Java\apache-activemq-5.4.0\bin\activemq-admin.bat start xbean:activemq-stomp.xml

The Stomp client sends a number of binary messages but receives only the first one, the broker log on the console looks like this:

Java Runtime: Sun Microsystems Inc. 1.6.0_07 C:\Program Files\Java\jdk1.6.0_07\j
re
Heap sizes: current=5056k free=4360k max=520256k
JVM args: -Dcom.sun.management.jmxremote -Xmx512M -Dorg.apache.activemq.UseD
edicatedTaskRunner=true -Djava.util.logging.config.file=logging.properties -Dact
ivemq.classpath=C:\Java\apache-activemq-5.4.0\bin\../conf; -Dactivemq.home=C:\Ja
va\apache-activemq-5.4.0\bin\.. -Dactivemq.base=C:\Java\apache-activemq-5.4.0\bi
n\..
ACTIVEMQ_HOME: C:\Java\apache-activemq-5.4.0\bin\..
ACTIVEMQ_BASE: C:\Java\apache-activemq-5.4.0\bin\..
Loading message broker from: xbean:activemq-stomp.xml
INFO | PListStore:C:\Java\apache-activemq-5.4.0\bin\..\data\localhost\tmp_stora
ge started
INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\Java\apache-activ
emq-5.4.0\bin\..\data\kahadb]
INFO | ActiveMQ 5.4.0 JMS Message Broker (localhost) is starting
INFO | For help or more information please see: http://activemq.apache.org/
INFO | Scheduler using directory: activemq-data\scheduler
INFO | Listening for connections at: stomp://mj-PC:61612?transport.closeAsync=f
alse
INFO | Connector stomp Started
INFO | Listening for connections at: stomp+nio://mj-PC:61613?transport.closeAsy
nc=false
INFO | Connector stomp+nio Started
INFO | ActiveMQ JMS Message Broker (localhost, ID:mj-PC-49520-1283080154792-0:0
) started
INFO | Logging to org.slf4j.impl.JCLLoggerAdapter(org.eclipse.jetty.util.log) v
ia org.eclipse.jetty.util.log.Slf4jLog
INFO | jetty-7.0.1.v20091125
INFO | ActiveMQ WebConsole initialized.
INFO | Initializing Spring FrameworkServlet 'dispatcher'
INFO | ActiveMQ Console at http://0.0.0.0:8161/admin
INFO | Initializing Spring root WebApplicationContext
INFO | Connector vm://localhost Started
INFO | Camel Console at http://0.0.0.0:8161/camel
INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo
INFO | RESTful file access application at http://0.0.0.0:8161/fileserver
INFO | Started SelectChannelConnector@0.0.0.0:8161
INFO | Transport failed: java.io.EOFException
java.io.EOFException
at org.apache.activemq.transport.stomp.StompNIOTransport.serviceRead(Sto
mpNIOTransport.java:106)
at org.apache.activemq.transport.stomp.StompNIOTransport.access$000(Stom
pNIOTransport.java:51)
at org.apache.activemq.transport.stomp.StompNIOTransport$1.onSelect(Stom
pNIOTransport.java:80)
at org.apache.activemq.transport.nio.SelectorSelection.onSelect(Selector
Selection.java:94)
at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker
.java:119)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:885)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:907)
at java.lang.Thread.run(Thread.java:619)

The Stomp client log is:

TCoreIndyTests.TestBytesMessages
send:
CONNECT

received:
CONNECTED
session:ID:mj-PC-49520-1283080154792-5:0

send:
SUBSCRIBE
destination:/queue/HabariSpeedTest
ack:auto
id:

{E4BD9658-B92E-4C57-AD9F-F5357BA66FC2}



send:
SEND
destination:/queue/HabariSpeedTest
content-length:4
correlation-id:{5B735F2D-349E-4A8A-B2AE-6493A1569F88}

☺☻♥1

send:
SEND
destination:/queue/HabariSpeedTest
content-length:4
correlation-id:{5B735F2D-349E-4A8A-B2AE-6493A1569F88}

☺☻♥2

send:

(more messages, ten total)

received:
MESSAGE
message-id:ID:mj-PC-49520-1283080154792-5:0:-1:1:1
destination:/queue/HabariSpeedTest
timestamp:1283080192048
expires:0
subscription:{E4BD9658-B92E-4C57-AD9F-F5357BA66FC2}

content-length:4
priority:0
correlation-id:

{5B735F2D-349E-4A8A-B2AE-6493A1569F88}

☺☻♥1

Received 1 messages
Elapsed: 10000 msec (limit: 10000 msec) - giving up
send:
DISCONNECT

Not sure if this is related but I also see an error in the startup log on later restarts. I reinstalled the broker and the message disappears.

INFO | jetty-7.0.1.v20091125
INFO | ActiveMQ WebConsole initialized.
INFO | Initializing Spring FrameworkServlet 'dispatcher'
INFO | ActiveMQ Console at http://0.0.0.0:8161/admin
INFO | Initializing Spring root WebApplicationContext
ERROR | Could not accept connection : java.nio.channels.ClosedSelectorException <------------------
INFO | Connector vm://localhost Started
INFO | Camel Console at http://0.0.0.0:8161/camel
INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo
INFO | RESTful file access application at http://0.0.0.0:8161/fileserver
INFO | Started SelectChannelConnector@0.0.0.0:8161