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 <[email protected]> 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
