btw: what is your use case for using the http transport rather than
tcp? Is it firewall traversal?
On 16 July 2010 11:20, Gary Tully <gary.tu...@gmail.com> wrote:
> this looks like a bug, can u raise a jira issue with this test code
> and attach your broker side activemq.xml so the configuration of the
> http server transport is visible.
>
> I think it looks like the http transport should be creating a
> faultolerant connectionInfo, because http is an async transport it has
> no way of seeing the connection disconnect in this case.
>
> On 16 July 2010 10:56, RJtokenlanring <ing.marco.colo...@gmail.com> wrote:
>>
>> //CODE
>> public class TestVaseClientID {
>>
>> public static void main(String[] args) {
>> try {
>> ActiveMQConnectionFactory connectionFactory = new
>> ActiveMQConnectionFactory("user", "default", "http://192.168.100.88:61617";);
>> Connection connection =
>> connectionFactory.createConnection();
>> String clid = "myclid";
>> connection.setClientID(clid);
>> connection.start();
>>
>> // Create the session
>> Session msess = connection.createSession(true,
>> Session.AUTO_ACKNOWLEDGE);
>> Topic destination =
>> msess.createTopic("topic/myDurableTopic");
>>
>> TopicSubscriber tsub =
>> msess.createDurableSubscriber((Topic)destination,
>> clid, "(InputSel = '10')", false);
>> while(true){
>> System.out.println("Receiving....");
>> tsub.receive(10000);
>> }
>> } catch (JMSException e) {
>> e.printStackTrace();
>> }
>>
>> }
>> }
>>
>> //RECONNECTION ERROR
>> javax.jms.InvalidClientIDException: Broker: localhost - Client: myclid
>> already connected from blockingQueue_20984287
>> at
>> org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:216)
>> at
>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
>> at
>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
>> at
>> org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:77)
>> at
>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:82)
>> --
>> View this message in context:
>> http://old.nabble.com/Set-ClientID---InvalidClientIDException-tp29172904p29181951.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
>
> --
> http://blog.garytully.com
>
> Open Source Integration
> http://fusesource.com
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
