Return-Path: 
 <users-return-18174-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 68087 invoked from network); 2 Mar 2009 17:22:38 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 2 Mar 2009 17:22:38 -0000
Received: (qmail 66051 invoked by uid 500); 2 Mar 2009 17:22:36 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 66028 invoked by uid 500); 2 Mar 2009 17:22:36 -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 66016 invoked by uid 99); 2 Mar 2009 17:22:36 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Mar 2009 09:22:36 -0800
X-ASF-Spam-Status: No, hits=2.6 required=10.0
	tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Mar 2009 17:22:26 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1LeBq9-0002UB-Al
	for users@activemq.apache.org; Mon, 02 Mar 2009 09:22:05 -0800
Message-ID: <22292440.post@talk.nabble.com>
Date: Mon, 2 Mar 2009 09:22:05 -0800 (PST)
From: "A. Gregory Rabil" <greg.rabil@ins.com>
To: users@activemq.apache.org
Subject: Re: QueueBrowser with Network of Brokers
In-Reply-To: <11128713.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: greg.rabil@ins.com
References: <9335320.post@talk.nabble.com>
 <ec6e67fd0703060818g6169be71t28620291dc8f53d1@mail.gmail.com>
 <9338842.post@talk.nabble.com> <11128713.post@talk.nabble.com>
X-Virus-Checked: Checked by ClamAV on apache.org


I am seeing this same problem in AMQ 4.1.1 and 4.1.2.  Is there any
resolution to this issue?

Regards,
Greg Rabil


AlB wrote:
> 
> I have a network of 3 brokers using 4.0.1 where the maximum hop is 1 (a
> star configuration, a-b-c, where messages travel from a to b or b to c via
> the same queue.) Messages are not transacted by either the publishers or
> the consumer.
> 
> I see this error frequently. Sometimes the error will happen at startup,
> or during the transmition of thousands of messages, or when a message
> hasn't gone through in hours (and tens of thousands were earlier
> successfully transmitted). Once it happens, subsequent messages remain on
> the queue on the broker where the publisher is local (as seen by hermes). 
> 
> I have not been able to determine a specific action that causes this to
> happen.
> 
> The only thing that seems to make the system work is to restart the
> brokers on all three machines. However, the error usually reoccurs within
> 0-12 hours.
> 
> Are there configuration options that can be used to avoid this error?
> 
> Here are the network specs:
> 
> system B:
>     <networkConnector conduitSubscriptions="false" dynamicOnly="false"
> failover="true" name="pickling" networkTTL="3"
> uri="static:(ssl://192.168.131.64:61817)"/>
> <networkConnector conduitSubscriptions="false" dynamicOnly="false"
> failover="true" name="pez" networkTTL="3"
> uri="static:(ssl://192.168.86.155:61817)"/>
> </networkConnectors>
> 
> System A/C:
>     <networkConnector conduitSubscriptions="false" dynamicOnly="false"
> failover="true" name="jolt" networkTTL="3"
> uri="static:(ssl://192.168.86.156:61817)"/>
> 
> 
> davem wrote:
>> 
>> Here is the stack trace:
>> 
>> java.lang.NullPointerException
>>         at
>> org.apache.activemq.network.DemandForwardingBridgeSupport.configureMessage(DemandForwardingBridgeSupport.java:465)
>>         at
>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLocalCommand(DemandForwardingBridgeSupport.java:486)
>>         at
>> org.apache.activemq.network.DemandForwardingBridgeSupport$1.onCommand(DemandForwardingBridgeSupport.java:121)
>>         at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
>>         at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
>>         at
>> org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
>>         at
>> org.apache.activemq.transport.vm.VMTransport.oneWay(VMTransport.java:83)
>>         at
>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:43)
>>         at
>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>>         at
>> org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:105)
>>         at
>> org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:772)
>>         at
>> org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:788)
>>         at
>> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:111)
>>         at
>> org.apache.activemq.thread.PooledTaskRunner.access$100(PooledTaskRunner.java:26)
>>         at
>> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:44)
>>         at
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>>         at
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>>         at java.lang.Thread.run(Thread.java:595)
>> 
>> The "receiver" application has a broker:
>>   <broker brokerName="receiver" persistent="false" useJmx="false">
>>     <transportConnectors>
>>       <transportConnector uri="tcp://localhost:7002"/>
>>     </transportConnectors>
>> 
>>     <networkConnectors>
>>       <networkConnector uri="static:(tcp://localhost:7001)"
>> failover="true"/>
>>     </networkConnectors>
>> 
>>     <persistenceAdapter>
>>       <memoryPersistenceAdapter/>
>>     </persistenceAdapter>
>>   </broker>
>> 
>> The "sender" application has a broker:
>>   <broker brokerName="sender" persistent="false" useJmx="false">
>>     <transportConnectors>
>>       <transportConnector uri="tcp://localhost:7001"/>
>>     </transportConnectors>
>> 
>>     <networkConnectors>
>>       <networkConnector uri="static:(tcp://localhost:7002)"
>> failover="true"/>
>>     </networkConnectors>
>> 
>>     <persistenceAdapter>
>>       <memoryPersistenceAdapter/>
>>     </persistenceAdapter>
>>   </broker>
>> 
>> A third "browser" application uses a connection factory with a url like
>> "tcp://localhost:7002".  If the browser connects to the "receiver"
>> application and creates a QueueBrowser, then that exception is thrown in
>> the "sender" application.
>> 
>> 
>> James.Strachan wrote:
>>> 
>>> On 3/6/07, davem <dmowatt@gmail.com> wrote:
>>>>
>>>> Hello,
>>>>
>>>> Should a QueueBrowser work against a queue in a broker that is part of
>>>> a
>>>> network of brokers in 4.1.0?
>>> 
>>> Sure.
>>> 
>>>>  If I have two brokers in a network (each with
>>>> a static network connector to the other) and I browse a queue on one of
>>>> the
>>>> two, then an INFO message is logged on the other broker that the
>>>> connection
>>>> between the brokers failed and has been recreated.  The cause of the
>>>> failure
>>>> is a NullPointerException from
>>>> DemandForwardingBridgeSupport.configureMessage.
>>> 
>>> Do you have a full stack trace? Sounds like a bug.
>>> 
>>> -- 
>>> 
>>> James
>>> -------
>>> http://radio.weblogs.com/0112098/
>>> 
>>> 
>> 
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/QueueBrowser-with-Network-of-Brokers-tp9335320p22292440.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.