activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ivan <xhh...@gmail.com>
Subject Re: EOFException in ActiveMQ 4.1.2
Date Fri, 17 Dec 2010 02:46:59 GMT
After adding some outputs, the error seems to happen after the socket of the
server side received the wireformatinfo, then on the next call of
readCommand, it fails to read bytes ...

-->
2010-12-17 10:42:13,046 INFO  [TcpTransport] BEGIN  TAG [1292553733046-99-1]
Receive command [LOCAL [/127.0.0.1:61616 ] REMOTE [/127.0.0.1:2843]]
2010-12-17 10:42:13,046 DEBUG [WireFormatNegotiator] Sending: WireFormatInfo
{ version=2, properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
CacheSize=1024, StackTraceEnabled=true, MaxInactivityDuration=30000,
SizePrefixDisabled=false, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2010-12-17 10:42:13,046 INFO  [TcpTransport$MonitorDataOutput] BEGIN
writeInt() v = [174]
2010-12-17 10:42:13,046 INFO  [TcpTransport$MonitorDataOutput] END
writeInt()
2010-12-17 10:42:13,046 INFO  [TcpTransport$MonitorDataOutput] BEGIN
write(byte[] b, int off, int len) b = [ [B@73507350] off = [0] len = [174]
2010-12-17 10:42:13,046 INFO  [TcpTransport$MonitorDataOutput] END
write(byte[] b, int off, int len)
2010-12-17 10:42:13,046 INFO  [TcpTransport] BEGIN  TAG [1292553733046-98-1]
Receive command [LOCAL [/127.0.0.1:2843 ] REMOTE [localhost/127.0.0.1:61616
]]
2010-12-17 10:42:13,046 INFO  [TcpBufferedInputStream] fill() n = [178]
position = [0] count = [0] thread id = [99]
2010-12-17 10:42:13,046 INFO  [TcpTransport] command [WireFormatInfo {
version=2, properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
CacheSize=1024, StackTraceEnabled=true, MaxInactivityDuration=30000,
SizePrefixDisabled=false, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}] is
send correctly [LOCAL [/127.0.0.1:2843 ] REMOTE [localhost/127.0.0.1:61616]]
2010-12-17 10:42:13,046 INFO  [TcpTransport] END     TAG
[1292553733046-99-1] Receive command [LOCAL [/127.0.0.1:61616 ] REMOTE [/
127.0.0.1:2843]] command = [WireFormatInfo { version=2,
properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
CacheSize=1024, StackTraceEnabled=true, MaxInactivityDuration=30000,
CacheEnabled=true, SizePrefixDisabled=false}, magic=[A,c,t,i,v,e,M,Q]}]
2010-12-17 10:42:13,046 DEBUG [WireFormatNegotiator] Received WireFormat:
WireFormatInfo { version=2, properties={TightEncodingEnabled=true,
TcpNoDelayEnabled=true, CacheSize=1024, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true, SizePrefixDisabled=false},
magic=[A,c,t,i,v,e,M,Q]}
2010-12-17 10:42:13,046 DEBUG [WireFormatNegotiator] LOCAL [
0.0.0.0/0.0.0.0:61616 ] REMOTE [/127.0.0.1:2843] before negotiation:
OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false}
2010-12-17 10:42:13,046 DEBUG [WireFormatNegotiator] LOCAL [
0.0.0.0/0.0.0.0:61616 ] REMOTE [/127.0.0.1:2843] after negotiation:
OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true,
tightEncodingEnabled=true, sizePrefixDisabled=false}
2010-12-17 10:42:13,046 INFO  [TcpTransport] BEGIN  TAG [1292553733046-99-2]
Receive command [LOCAL [0.0.0.0/0.0.0.0:61616 ] REMOTE [/127.0.0.1:2843]]
2010-12-17 10:42:13,046 INFO  [TcpBufferedInputStream] fill() n = [-1]
position = [0] count = [0] thread id = [99]
2010-12-17 10:42:13,046 INFO  [TcpBufferedInputStream] fill() n = [-1]
position = [0] count = [0] thread id = [99]
2010-12-17 10:42:13,046 INFO  [TcpBufferedInputStream] fill() n = [-1]
position = [0] count = [0] thread id = [99]
2010-12-17 10:42:13,046 INFO  [TcpBufferedInputStream] fill() n = [-1]
position = [0] count = [0] thread id = [99]
2010-12-17 10:42:13,046 INFO  [TcpTransport] END      TAG
[1292553733046-99-2] Receive command [LOCAL [0.0.0.0/0.0.0.0:61616 ] REMOTE
[/127.0.0.1:2843]]
java.io.EOFException
    at java.io.DataInputStream.readInt(DataInputStream.java:387)
    at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
    at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:268)
    at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:244)
    at java.lang.Thread.run(Thread.java:736)
<--

2010/12/17 Ivan <xhhsld@gmail.com>

> Hi,
>   I am using Geronimo 2.1.7, which shipped ActiveMQ 4.1.2, it sometimes
> reported the error below after deploying a MDB. I know that ActiveMQ 4.1.2
> is a very very old version, but ....
>   I hope some one could help to give some hints, so that I could port some
> changes from the trunk.
>   Thanks.
>   --->
> 2010-12-17 09:56:56,875 ERROR [TransportConnector] Could not accept
> connection from /127.0.0.1:1823: java.io.IOException: The transport is n
> ot running.
> java.io.IOException: The transport is not running.
>         at
> org.apache.activemq.transport.TransportSupport.checkStarted(TransportSupport.java:103)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:125)
>         at
> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:145)
>         at
> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:80)
>         at
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:93)
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
>         at
> org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1138)
>         at
> org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:805)
>         at
> org.apache.activemq.broker.TransportConnection.start(TransportConnection.java:885)
>         at
> org.apache.activemq.broker.TransportConnector$1.onAccept(TransportConnector.java:148)
>         at
> org.apache.activemq.transport.tcp.TcpTransportServer.run(TcpTransportServer.java:162)
>         at java.lang.Thread.run(Thread.java:736)
> <---
>
> Also, I could find the exception message below in the log
> --->
>   java.io.EOFException
>     at java.io.DataInputStream.readInt(DataInputStream.java:387)
>     at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
>     at
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:269)
>     at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:245)
>     at java.lang.Thread.run(Thread.java:736)
> <---
> --
> Ivan
>



-- 
Ivan

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message