You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2008/09/08 16:55:57 UTC
[jira] Updated: (AMQ-1102) Infinite loop from broker's network
connector when using multiple durable subscribers (topics) with msg
selector.
[ https://issues.apache.org/activemq/browse/AMQ-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully updated AMQ-1102:
----------------------------
Fix Version/s: 5.3.0
(was: 5.2.0)
> 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
> Fix For: 5.3.0
>
>
> 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.