You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Aleksi Kallio <al...@csc.fi> on 2007/01/18 16:43:56 UTC
Dropped IP packets (was: Re: Connection reset by peer: socket write
error)
I found this when looking for help to my problem:
Hiram Chirino wrote:
> if the OS can't keep up with the ip packets due to full 100% CPU usage it
> will start to close sockets. And thus activemq will see jms connections
> being dropped
Would dropped IP packets be the reason why I'm getting
"javax.jms.JMSException: Connection reset" every time I try to send
something substantial?
This problem arose after optimising my code, which allowed it to process
incoming much faster. We are talking about a single large message here.
Any good ideas how to resolve this?
My connection string is "tcp://hostname:61616". The full stack trace is:
javax.jms.JMSException: Connection reset
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:45)
at
org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1443)
at
org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1459)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
at
org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:120)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
at
org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:120)
at
org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)
at
org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:100)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:156)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:168)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
at java.io.DataInputStream.readInt(DataInputStream.java:353)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
... 1 more
Re: Dropped IP packets
Posted by Aleksi Kallio <al...@csc.fi>.
Hi,
I've found out the reason for this: my messages were too large. So I'll
have to employ streaming!
>
> I found this when looking for help to my problem:
>
> Hiram Chirino wrote:
>> if the OS can't keep up with the ip packets due to full 100% CPU usage it
>> will start to close sockets. And thus activemq will see jms connections
>> being dropped
>
> Would dropped IP packets be the reason why I'm getting
> "javax.jms.JMSException: Connection reset" every time I try to send
> something substantial?
>
> This problem arose after optimising my code, which allowed it to process
> incoming much faster. We are talking about a single large message here.
>
> Any good ideas how to resolve this?
>
>
> My connection string is "tcp://hostname:61616". The full stack trace is:
>
> javax.jms.JMSException: Connection reset
> at
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:45)
>
> at
> org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1443)
>
> at
> org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1459)
>
> at
> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:120)
>
> at
> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
>
> at
> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
>
> at
> org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:120)
>
> at
> org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)
>
> at
> org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:100)
>
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:156)
> at java.lang.Thread.run(Thread.java:595)
> Caused by: java.net.SocketException: Connection reset
> at java.net.SocketInputStream.read(SocketInputStream.java:168)
> at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
>
> at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
>
> at java.io.DataInputStream.readInt(DataInputStream.java:353)
> at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> ... 1 more
>