activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: Set ClientID - InvalidClientIDException
Date Fri, 16 Jul 2010 10:47:28 GMT
you will need to create an account in the issue tracker:
https://issues.apache.org/activemq/browse/AMQ, there is no restriction
on account creation.

On 16 July 2010 11:42, RJtokenlanring <ing.marco.colombo@gmail.com> wrote:
>
> 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.
>
>



-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

Mime
View raw message