activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bruce Snyder (JIRA)" <j...@apache.org>
Subject [jira] Closed: (AMQ-1102) Infinite loop from broker's network connector when using multiple durable subscribers (topics) with msg selector.
Date Fri, 20 Nov 2009 20:51:52 GMT

     [ https://issues.apache.org/activemq/browse/AMQ-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Bruce Snyder closed AMQ-1102.
-----------------------------

       Resolution: Cannot Reproduce
    Fix Version/s:     (was: AGING_TO_DIE)

> Infinite loop from broker's network connector when using multiple durable subscribers
(topics) with msg selector.
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1102
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1102
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 4.1.0
>         Environment: Linux
>            Reporter: Samson
>
> The following is the series of messages resulting from the broker (infinite loop):
> 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
> ...
> EXACT 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
> 	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

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message