Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <11157217.3071283168380940.JavaMail.jira@thor>
Date: Mon, 30 Aug 2010 07:39:40 -0400 (EDT)
From: "Daniel Peters (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Commented: (AMQ-2883) EOFException if stomp+nio after
 ActiveMQ has sent the first bytes message
In-Reply-To: <18357886.2571283080900862.JavaMail.jira@thor>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable


    [ https://issues.apache.org/activemq/browse/AMQ-2883?page=3Dcom.atlassi=
an.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D61=
501#action_61501 ]=20

Daniel Peters commented on AMQ-2883:
------------------------------------

I just updated our server from 5.3.2 to 5.4.0 and I get the same error with=
 Stomp:
2010-08-30 12:43:11,681 | INFO  | Transport failed: java.io.EOFException | =
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ NIO Wor=
ker
java.io.EOFException
        at org.apache.activemq.transport.stomp.StompNIOTransport.serviceRea=
d(StompNIOTransport.java:106)
        at org.apache.activemq.transport.stomp.StompNIOTransport.access$000=
(StompNIOTransport.java:51)
        at org.apache.activemq.transport.stomp.StompNIOTransport$1.onSelect=
(StompNIOTransport.java:80)
        at org.apache.activemq.transport.nio.SelectorSelection.onSelect(Sel=
ectorSelection.java:94)
        at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorW=
orker.java:119)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoo=
lExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExe=
cutor.java:908)
        at java.lang.Thread.run(Thread.java:619)

We had to switch back to 5.3.2 because we have alot stomp clients. :(

It doesnt work without NIO either:
2010-08-30 12:55:15,536 | INFO  | Transport failed: java.io.EOFException | =
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transpo=
rt: tcp:///192.168.2.89:37025
java.io.EOFException
        at java.io.DataInputStream.readByte(DataInputStream.java:250)
        at org.apache.activemq.transport.stomp.StompWireFormat.readLine(Sto=
mpWireFormat.java:146)
        at org.apache.activemq.transport.stomp.StompWireFormat.parseAction(=
StompWireFormat.java:162)
        at org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(St=
ompWireFormat.java:92)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTr=
ansport.java:226)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTranspor=
t.java:218)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.=
java:201)
        at java.lang.Thread.run(Thread.java:619)


> EOFException if stomp+nio after ActiveMQ has sent the first bytes message
> -------------------------------------------------------------------------
>
>                 Key: AMQ-2883
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2883
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Transport
>    Affects Versions: 5.4.0
>         Environment: Windows Vista
>            Reporter: Michael Justin
>
> 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=3D5056k  free=3D4360k  max=3D520256k
>     JVM args: -Dcom.sun.management.jmxremote -Xmx512M -Dorg.apache.active=
mq.UseD
> edicatedTaskRunner=3Dtrue -Djava.util.logging.config.file=3Dlogging.prope=
rties -Dact
> ivemq.classpath=3DC:\Java\apache-activemq-5.4.0\bin\../conf; -Dactivemq.h=
ome=3DC:\Ja
> va\apache-activemq-5.4.0\bin\.. -Dactivemq.base=3DC:\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\tm=
p_stora
> ge started
>  INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\Java\apach=
e-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.o=
rg/
>  INFO | Scheduler using directory: activemq-data\scheduler
>  INFO | Listening for connections at: stomp://mj-PC:61612?transport.close=
Async=3Df
> alse
>  INFO | Connector stomp Started
>  INFO | Listening for connections at: stomp+nio://mj-PC:61613?transport.c=
loseAsy
> nc=3Dfalse
>  INFO | Connector stomp+nio Started
>  INFO | ActiveMQ JMS Message Broker (localhost, ID:mj-PC-49520-1283080154=
792-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.serviceR=
ead(Sto
> mpNIOTransport.java:106)
>         at org.apache.activemq.transport.stomp.StompNIOTransport.access$0=
00(Stom
> pNIOTransport.java:51)
>         at org.apache.activemq.transport.stomp.StompNIOTransport$1.onSele=
ct(Stom
> pNIOTransport.java:80)
>         at org.apache.activemq.transport.nio.SelectorSelection.onSelect(S=
elector
> Selection.java:94)
>         at org.apache.activemq.transport.nio.SelectorWorker$1.run(Selecto=
rWorker
> .java:119)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadP=
oolExec
> utor.java:885)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolE=
xecutor
> .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}
> =E2=98=BA=E2=98=BB=E2=99=A51
> send:
> SEND
> destination:/queue/HabariSpeedTest
> content-length:4
> correlation-id:{5B735F2D-349E-4A8A-B2AE-6493A1569F88}
> =E2=98=BA=E2=98=BB=E2=99=A52
> 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}
> =E2=98=BA=E2=98=BB=E2=99=A51
> 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.ClosedSelectorExc=
eption  <------------------
>  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

--=20
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.