activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Samson Kwok <turin...@yahoo.com>
Subject Re: Infinite loop from network connector w/ mult durable sub & msg selector
Date Mon, 18 Dec 2006 21:57:04 GMT
Opened up a JIRA issue for this since there were no
comments on this problem.

http://issues.apache.org/activemq/browse/AMQ-1102

--- Samson Kwok <turing_1@yahoo.com> wrote:

> I get the following loop from activemq's network
> connector (version 4.1) when I try to start up 2
> durable subscribers w/ msg selector:
> 
> 
> INFO  DemandForwardingBridge         - Network
> connection between vm://localhost#0 and
> tcp://localhost/127.0.0.1:61601 shutdown due to a
> local error: javax.jms.JMSException: Durable
> consumer
> is in use for client:
> NC_SWITCH1BROKER_inboundlocalhost and
> subscriptionName: localhost_TEST.FOO
> INFO  TransportConnector             - Connector
> vm://localhost Stopped
> INFO  NetworkConnector               - Establishing
> network connection between from
> vm://localhost?network=true to tcp://switch:61601
> INFO  TransportConnector             - Connector
> vm://localhost Started
> INFO  DemandForwardingBridge         - Network
> connection between vm://localhost#2 and
> tcp://localhost/127.0.0.1:61601(SWITCH1BROKER) has
> been established.
> INFO  DemandForwardingBridge         - Network
> connection between vm://localhost#2 and
> tcp://localhost/127.0.0.1:61601 shutdown due to a
> local error: javax.jms.JMSException: Durable
> consumer
> is in use for client:
> NC_SWITCH1BROKER_inboundlocalhost and
> subscriptionName: localhost_TEST.FOO
> INFO  TransportConnector             - Connector
> vm://localhost Stopped
> ...
> 
> 
> STEPS TO REPRODUCE:
> 
> 1  -Start standalone broker
> 	-using default conf/activemq.xml file
> 
> 2  -Start EmbeddedBroker (with network connector
> specified):
> 	BrokerService broker = new BrokerService();
>         	broker.setUseJmx(true);
>         	broker.setBrokerName("SWITCH1BROKER");
> 
> 	TransportConnector connector =
> 	    broker.addConnector(new
> URI("tcp://localhost:"+61601));
> 	connector.setDiscoveryUri(new
> URI("multicast://default"));
> 	broker.addNetworkConnector(new
> URI("multicast://default"));
> 
> 	broker.start();
> 
> At this point, I'll get the following output (which
> looks normal):
> 
> INFO  NetworkConnector               - Establishing
> network connection between from
> vm://localhost?network=true to tcp://switch:61601
> INFO  TransportConnector             - Connector
> vm://localhost Started
> INFO  DemandForwardingBridge         - Network
> connection between vm://localhost#0 and
> tcp://localhost/127.0.0.1:61601(SWITCH1BROKER) has
> been established.
> 
> 
> 3.  -Edit line 105 of ConsumerTool to specify any
> message selector, for example:
> 	consumer = session.createDurableSubscriber((Topic)
> destination,
> 	    consumerName, "BLAH = '1'", false);
> 
> 4.  -Start ConsumerTool with clientID consumer1
> 	-connect to tcp://localhost:61601
> 	-using topics, durable subscription, w/ message
> selector
> 
> 5.  -Start ConsumerTool with clientID consumer2
> 	-connect to tcp://localhost:61601
> 	-using topics, durable subscription, w/ message
> selector
> 
> 
> 
> 
>  
>
____________________________________________________________________________________
> Need a quick answer? Get one in minutes from people
> who know.
> Ask your question on www.Answers.yahoo.com
> 


__________________________________________________
Do You Yahoo!?
Tired of spam?  Yahoo! Mail has the best spam
protection around 
http://mail.yahoo.com 

__________________________________________________
Do You Yahoo!?
Tired of spam?  Yahoo! Mail has the best spam protection around 
http://mail.yahoo.com 

Mime
View raw message