Are you creating two network connections - i.e. one on each broker - or just one network connection on one broker?
ttmdev wrote: > > I am trying to connect two 5.0 brokers via a duplex network connection > without much success (see exception stack below). I am using the latest > 5.0 snapshot. If I take out "duplex=true", both brokers are happy-campers > and life is good. Has the duplex feature been fully implemented? - Thanks > > > ERROR Service - Async error occurred: > javax.jms.InvalidCl > ientIDException: Broker: mybroker1 - Client: NC_mybroker2_inboundmybroker1 > alrea > dy connected from vm://mybroker1#0 > javax.jms.InvalidClientIDException: Broker: mybroker1 - Client: > NC_mybroker2_inb > oundmybroker1 already connected from vm://mybroker1#0 > at > org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBr > oker.java:205) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.ja > va:81) > at > org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBro > ker.java:71) > at > org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.ja > va:81) > at > org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableB > rokerFilter.java:91) > at > org.apache.activemq.broker.TransportConnection.processAddConnection(T > ransportConnection.java:690) > at > org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java: > 125) > at > org.apache.activemq.broker.TransportConnection.service(TransportConne > ction.java:320) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC > onnection.java:216) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo > rrelator.java:100) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt > er.java:67) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java > :232) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskR > unner.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRun > ner.java:36) > INFO DemandForwardingBridge - Network connection between > vm://mybroker1 > #4 and tcp://localhost/127.0.0.1:61617(mybroker2) has been established. > INFO DemandForwardingBridge - Network connection between > vm://mybroker1 > #4 and tcp://localhost/127.0.0.1:61617 shutdown due to a local error: > javax.jms. > InvalidClientIDException: Broker: mybroker1 - Client: > NC_mybroker2_inboundmybrok > er1 already connected from vm://mybroker1#0 > ERROR Service - Async error occurred: > java.lang.IllegalSt > ateException: Cannot add a consumer to a session that had not been > registered: I > D:DIEGO-3893-1190136710171-5:1:1 > java.lang.IllegalStateException: Cannot add a consumer to a session that > had not > been registered: ID:DIEGO-3893-1190136710171-5:1:1 > at > org.apache.activemq.broker.TransportConnection.processAddConsumer(Tra > nsportConnection.java:559) > at > org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:334) > > at > org.apache.activemq.broker.TransportConnection.service(TransportConne > ction.java:320) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC > onnection.java:216) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo > rrelator.java:100) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt > er.java:67) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java > :232) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskR > unner.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRun > ner.java:36) > > > > > > > PieterN wrote: >> >> >> rajdavies wrote: >>> >>> nothing to be worried about - you've just encountered a half finished >>> implementation of duplex network connections. Hopefully this is fixed >>> in today's snapshot >>> >> Using the latest snapshot (from august 5), I still encounter this >> problem. I also sometimes receive duplicate messages, or get errors when >> i try to ACK a message. Anyone else seeing this problems? >> >> Regards, >> >> Pieter >> > > -- View this message in context: http://www.nabble.com/Unexpected-remote-command-tf4179394s2354.html#a13112730 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
