activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: Error javax.jms.JMSException: Broken pipe
Date Tue, 10 Sep 2013 20:31:48 GMT
This belongs on the users mailing list.

Looks like some how (firewall?) your connection got dropped and the tcp
session was interrupted.


On Mon, Sep 9, 2013 at 11:34 PM, joneron <joneron2013@gmail.com> wrote:

> hi all;
>
> 1.using ActiveMQ version is ActiveMQ 5.8
> 2.using JVM version is jdk1.6.24 (64bit)
> 3.using operating system is linux (64bit)
> 4.using topics and non persistent messaging send message
> 5.application server; spring2.5, tomcat6.0, J2EE
>
> ActiveMQ error log as follows:
> ------------------------------------------------------------
> 2013-09-07 01:58:47.046 [ActiveMQ Transport:
> tcp:///172.28.18.144:61616@40616] ERROR com.sgfm.core.sys.JMSRegister -
> JSM发送报文异常
> javax.jms.JMSException: Broken pipe
>         at
>
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1306)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1298)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1901)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.ActiveMQSession.sendAck(ActiveMQSession.java:2067)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.ActiveMQSession.sendAck(ActiveMQSession.java:2062)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQMessageConsumer.acknowledge(ActiveMQMessageConsumer.java:1061)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.ActiveMQSession.acknowledge(ActiveMQSession.java:1608)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQMessageConsumer$1.execute(ActiveMQMessageConsumer.java:552)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.command.ActiveMQMessage.acknowledge(ActiveMQMessage.java:99)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at com.sgfm.core.sys.JMSRegister$5.onMessage(JMSRegister.java:285)
> ~[TradeCore/:na]
>         at
>
> org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1321)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:131)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQSessionExecutor.execute(ActiveMQSessionExecutor.java:81)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.ActiveMQSession.dispatch(ActiveMQSession.java:1572)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQConnection$3.processMessageDispatch(ActiveMQConnection.java:1858)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.command.MessageDispatch.visit(MessageDispatch.java:113)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQConnection.onCommand(ActiveMQConnection.java:1838)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:288)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
> [activemq-client-5.8.0.jar:5.8.0]
>         at java.lang.Thread.run(Thread.java:662) [na:1.6.0_25]
> Caused by: java.net.SocketException: Broken pipe
>         at java.net.SocketOutputStream.socketWrite0(Native Method)
> ~[na:1.6.0_25]
>         at
> java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
> ~[na:1.6.0_25]
>         at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
> ~[na:1.6.0_25]
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedOutputStream.write(TcpBufferedOutputStream.java:72)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at java.io.DataOutputStream.writeBytes(DataOutputStream.java:259)
> ~[na:1.6.0_25]
>         at
>
> org.apache.activemq.openwire.v9.BaseDataStreamMarshaller.tightMarshalString2(BaseDataStreamMarshaller.java:342)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.v9.ProducerIdMarshaller.tightMarshal2(ProducerIdMarshaller.java:102)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.tightMarshalNestedObject2(OpenWireFormat.java:433)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.v9.BaseDataStreamMarshaller.tightMarshalCachedObject2(BaseDataStreamMarshaller.java:178)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.v9.MessageIdMarshaller.tightMarshal2(MessageIdMarshaller.java:102)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.tightMarshalNestedObject2(OpenWireFormat.java:433)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.v9.BaseDataStreamMarshaller.tightMarshalNestedObject2(BaseDataStreamMarshaller.java:135)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.v9.MessageAckMarshaller.tightMarshal2(MessageAckMarshaller.java:115)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:243)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:175)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:322)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:304)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
> ~[activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> [activemq-client-5.8.0.jar:5.8.0]
>         at
>
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1304)
> [activemq-client-5.8.0.jar:5.8.0]
>         ... 24 common frames omitted
> 2013-09-07 01:58:47.048 [ActiveMQ Transport:
> tcp:///172.28.18.144:61616@40616] ERROR com.sgfm.core.sys.JMSRegister -
> JSM发送报文异常
>
> ----------------------------------------------------------------------
>
>
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Error-javax-jms-JMSException-Broken-pipe-tp4671326.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

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