Return-Path: 
 <users-return-10944-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 97849 invoked from network); 10 Oct 2007 19:55:05 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 10 Oct 2007 19:55:05 -0000
Received: (qmail 87289 invoked by uid 500); 10 Oct 2007 19:54:51 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 87253 invoked by uid 500); 10 Oct 2007 19:54:51 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 87244 invoked by uid 99); 10 Oct 2007 19:54:51 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Oct 2007 12:54:51 -0700
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com
 designates 209.85.198.190 as permitted sender)
Received: from [209.85.198.190] (HELO rv-out-0910.google.com) (209.85.198.190)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Oct 2007 19:54:51 +0000
Received: by rv-out-0910.google.com with SMTP id l15so231055rvb
        for <users@activemq.apache.org>; Wed, 10 Oct 2007 12:53:44 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=beta;
        h=domainkey-signature:received:received:mime-version:in-reply-to:references:content-type:message-id:content-transfer-encoding:from:subject:date:to:x-mailer;
        bh=Y7C6otXS9qrIlOoBVhbGizpT5hgfIjctyhe6USzfdTc=;
        b=IDJjBaNr+wQhtwT51egXkSN2t0jm+iY4MF0kaieeMyiptaEcSWRjYxYepGXzaxyERFhgx5GTsWEcs33iD5naEhQQ2oN/WsBM4XxoIEBZIR1gbTSwH01OS7CroHkFvKE4kmGviqzfVDQuCFMBUWvsFu3jfqJdLF4V7O//24Jun+g=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=beta;
        h=received:mime-version:in-reply-to:references:content-type:message-id:content-transfer-encoding:from:subject:date:to:x-mailer;
        b=ShdyjcCF52UjwoTY292PAyH25/5WfjHTwMYXPk+zsNxttyQXGBzYQ4WG/LAtdmqFMSpdMopOp/+NzLLEvu1eui1BimKVlZO7VzTkHdwNzy7iaWFEgzxG4eu7+6xzePXCy6h5wLvpg84VnBS3YwGjOH0UAT6n0VMzpEYLixB3wnE=
Received: by 10.140.191.14 with SMTP id o14mr543205rvf.1192046023782;
        Wed, 10 Oct 2007 12:53:43 -0700 (PDT)
Received: from ?192.168.1.67? ( [86.130.75.52])
        by mx.google.com with ESMTPS id i7sm1998539nfh.2007.10.10.12.53.41
        (version=TLSv1/SSLv3 cipher=OTHER);
        Wed, 10 Oct 2007 12:53:42 -0700 (PDT)
Mime-Version: 1.0 (Apple Message framework v752.3)
In-Reply-To: <13115970.post@talk.nabble.com>
References: <11884587.post@talk.nabble.com>
 <BCB5F335-2AE5-447D-9D07-A49CB212C886@gmail.com>
 <12013759.post@talk.nabble.com> <12762491.post@talk.nabble.com>
 <13112730.post@talk.nabble.com> <13112758.post@talk.nabble.com>
 <13115970.post@talk.nabble.com>
Content-Type: text/plain; charset=US-ASCII; delsp=yes; format=flowed
Message-Id: <364D45F8-082B-475E-A3F1-9A5D68A104BD@gmail.com>
Content-Transfer-Encoding: 7bit
From: Rob Davies <rajdavies@gmail.com>
Subject: Re: Unexpected remote command
Date: Wed, 10 Oct 2007 20:53:34 +0100
To: users@activemq.apache.org
X-Mailer: Apple Mail (2.752.3)
X-Virus-Checked: Checked by ClamAV on apache.org

This is fixed in the svn main trunk


cheers,

Rob

http://rajdavies.blogspot.com/



On Oct 9, 2007, at 2:47 PM, ttmdev wrote:

>
> We are using the 'duplex' functionality for the same reason. I am  
> getting the
> same results whether I use this syntax, as in the distro test case
>
> <networkConnector uri="static:(tcp://localhost:61617)">
>            duplex=true
>               ....
> </networkConnector>
>
> or this one
>
> <networkConnector uri="static:(tcp://localhost:61617)" duplex="true">
>            ...
> </networkConnector>
>
> In both cases the broker initiating the connection comes up fine,  
> but when
> it connects to the remote broker I get the exceptions listed below.  
> However,
> I did notice that the broker accepting the connection request  
> reports this
> NPE.
>
> WARN  DemandForwardingBridge         - Network connection between
> vm://broker1#6
>  and tcp:///127.0.0.1:1929 shutdown due to a remote error:
> java.lang.NullPointer
> Exception
>
> Joe (ttmdev)
>
>
> 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#a13115970
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>