activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdavies <rajdav...@gmail.com>
Subject Re: Unexpected remote command
Date Tue, 09 Oct 2007 10:06:44 GMT

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.


Mime
View raw message