activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Unexpected remote command
Date Tue, 09 Oct 2007 10:23:15 GMT
Have you got a test case - there's a basic one in the distro - which  
passes.

thanks,

Rob
On Oct 9, 2007, at 11:11 AM, Alex_ynr wrote:

>
> I don't know about ttmdev but I am guessing he is creating it on  
> one side
> (just like I am).
>
> The whole idea (and the reason I'm using the duplex functionality)  
> is that
> one of the brokers is behind a firewall and cannot have an incoming
> connection...so I wanna set up an outgoing one from that broker to the
> outside one with duplex functionality.
>
> Any thoughts?
>
> Alex
>
>
> rajdavies wrote:
>>
>> 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#a13112758
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>


Mime
View raw message