activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jessezbj <jesse...@hotmail.com>
Subject Get exception in broker networks java.net.SocketException: Broken pipe
Date Sat, 25 Jun 2011 14:28:07 GMT
I have several brokers which form a network of brokers, then I am sending
messages each about 80kb , here is the exception I get, 

Caught an exception processing local command |
org.apache.activemq.network.DemandForwardingBridgeSupport |
BrokerService[broker-149-165-229-50] Task
java.net.SocketException: Broken pipe
	at java.net.SocketOutputStream.socketWrite0(Native Method)
	at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
	at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
	at
org.apache.activemq.transport.tcp.TcpBufferedOutputStream.write(TcpBufferedOutputStream.java:96)
	at java.io.DataOutputStream.write(DataOutputStream.java:90)
	at
org.apache.activemq.openwire.v6.BaseDataStreamMarshaller.tightMarshalByteSequence2(BaseDataStreamMarshaller.java:432)
	at
org.apache.activemq.openwire.v6.MessageMarshaller.tightMarshal2(MessageMarshaller.java:180)
	at
org.apache.activemq.openwire.v6.ActiveMQMessageMarshaller.tightMarshal2(ActiveMQMessageMarshaller.java:89)
	at
org.apache.activemq.openwire.v6.ActiveMQBytesMessageMarshaller.tightMarshal2(ActiveMQBytesMessageMarshaller.java:89)
	at
org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:237)
	at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:181)
	at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:255)
	at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
	at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
	at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
	at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
	at 

org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLocalCommand(DemandForwardingBridgeSupport.java:737)
	at
org.apache.activemq.network.DemandForwardingBridgeSupport$1.onCommand(DemandForwardingBridgeSupport.java:161)
	at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
	at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
	at
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:122)
	at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:113)
	at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
	at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
	at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1249)
	at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:810)
	at
org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:846)
	at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
	at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
	at java.lang.Thread.run(Thread.java:619)


--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-exception-in-broker-networks-java-net-SocketException-Broken-pipe-tp3624630p3624630.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message