The following code worked with AMQ4 M4
BrokerService brokerService = new BrokerService();
...
String connectors =static://(tcp://127.0.0.1:61616,tcp://127.0.0.1:61626);
brokerService.addNetworkConnector(networkConnector);
but after upgarding to AMQ4 RC2 message fowarding between the two broker no
longer works and I am getting the excpetion below. Any ideas on how to get
this to work?
TIA,
Richard
2006-04-13 22:14:55,655 ERROR [Thread-3]
org.apache.activemq.network.DemandForwardingBridge.error - Failed to start
network bridge: java.net.SocketException: Socket closed
java.net.SocketException: Socket closed
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:99)
at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
at
org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:108)
at java.io.DataOutputStream.flush(DataOutputStream.java:106)
at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:121)
at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:86)
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:77)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:55)
at
org.apache.activemq.network.DemandForwardingBridgeSupport.startRemoteBridge(DemandForwardingBridgeSupport.java:200)
at
org.apache.activemq.network.DemandForwardingBridgeSupport$4.run(DemandForwardingBridgeSupport.java:163)
--
View this message in context:
http://www.nabble.com/Embedded-Networked-Brokers-t1448274.html#a3912634
Sent from the ActiveMQ - User forum at Nabble.com.
