Re: Dropped IP packets

[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
>