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.
