activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From RJtokenlanring <ing.marco.colo...@gmail.com>
Subject Re: Set ClientID - InvalidClientIDException
Date Fri, 16 Jul 2010 10:42:34 GMT

Yes, the problem is the firewall. I need HTTP to do this.
Just one question: I don't have a JIRA account.
How can I submit this bug?

Regards


Gary Tully wrote:
> 
> 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.tully@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.colombo@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
> 
> 

-- 
View this message in context: http://old.nabble.com/Set-ClientID---InvalidClientIDException-tp29172904p29182299.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message