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.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
>
>
--
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.
