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 <[EMAIL PROTECTED]> 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
