Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 99106 invoked from network); 16 Jul 2010 10:48:00 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 16 Jul 2010 10:48:00 -0000 Received: (qmail 66303 invoked by uid 500); 16 Jul 2010 10:47:59 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 66117 invoked by uid 500); 16 Jul 2010 10:47:57 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 65541 invoked by uid 99); 16 Jul 2010 10:47:55 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 16 Jul 2010 10:47:55 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,NORMAL_HTTP_TO_IP,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL,WEIRD_PORT X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gary.tully@gmail.com designates 209.85.216.43 as permitted sender) Received: from [209.85.216.43] (HELO mail-qw0-f43.google.com) (209.85.216.43) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 16 Jul 2010 10:47:49 +0000 Received: by qwd6 with SMTP id 6so757732qwd.2 for ; Fri, 16 Jul 2010 03:47:28 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:received:in-reply-to :references:date:message-id:subject:from:to:content-type :content-transfer-encoding; bh=c1iOc2D4On/hcE3nT/AcoAiMgQIpubiiU4laSu88w5c=; b=kn56LSqcBoEqVw+MtfKpLThXYE+qez/hq3sjWA51Hbp4loP/+K5+1yfGAYQ4k3ZeAi ewuMSETDd5rZO9gQv9XWZFKnFoNV+2NhgHPHDMGKun2LQ6CBajpVMOilM3oPQY3MWQaZ +gdSKLVNBZaDlusVe4Tmv6CAhGk8cgROdtGHg= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type:content-transfer-encoding; b=S1sq3PUMf4jiJQCH4adhdWKRfwbXTirFeewYvS8a2OvrLlynn5YxjEXoJtCj1d9GQL S1KcFHPgPGvacEzFu6CKcbNLwDHqWKhcGuUEJghGCUWr/FztvMm0pJ8zCkHlmdehiujm TH0WjNgExOV7UPRqb58uGPRXXyEGPnlEzU6zQ= MIME-Version: 1.0 Received: by 10.224.79.83 with SMTP id o19mr892353qak.200.1279277248377; Fri, 16 Jul 2010 03:47:28 -0700 (PDT) Received: by 10.229.97.80 with HTTP; Fri, 16 Jul 2010 03:47:28 -0700 (PDT) In-Reply-To: <29182299.post@talk.nabble.com> References: <29172904.post@talk.nabble.com> <29173272.post@talk.nabble.com> <29173425.post@talk.nabble.com> <29181249.post@talk.nabble.com> <29181940.post@talk.nabble.com> <29181951.post@talk.nabble.com> <29182299.post@talk.nabble.com> Date: Fri, 16 Jul 2010 11:47:28 +0100 Message-ID: Subject: Re: Set ClientID - InvalidClientIDException From: Gary Tully To: users@activemq.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org 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 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 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 >>> wrote: >>>> >>>> //CODE >>>> public class TestVaseClientID { >>>> >>>> =A0 =A0 =A0 =A0public static void main(String[] args) { >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0try { >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0ActiveMQConnectionFacto= ry connectionFactory =3D new >>>> ActiveMQConnectionFactory("user", "default", >>>> "http://192.168.100.88:61617"); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Connection connection = =3D >>>> connectionFactory.createConnection(); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0String clid =3D "myclid= "; >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.setClientID(= clid); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0connection.start(); >>>> >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0// Create the session >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Session msess =3D conne= ction.createSession(true, >>>> Session.AUTO_ACKNOWLEDGE); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Topic destination =3D >>>> msess.createTopic("topic/myDurableTopic"); >>>> >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0TopicSubscriber tsub = =3D >>>> msess.createDurableSubscriber((Topic)destination, >>>> clid, "(InputSel =3D '10')", false); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0while(true){ >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0System.= out.println("Receiving...."); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0tsub.re= ceive(10000); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} catch (JMSException e) { >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0e.printStackTrace(); >>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0} >>>> >>>> =A0 =A0 =A0 =A0} >>>> } >>>> >>>> //RECONNECTION ERROR >>>> javax.jms.InvalidClientIDException: Broker: localhost - Client: myclid >>>> already connected from blockingQueue_20984287 >>>> =A0 =A0 =A0 =A0at >>>> org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBro= ker.java:216) >>>> =A0 =A0 =A0 =A0at >>>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.jav= a:82) >>>> =A0 =A0 =A0 =A0at >>>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.jav= a:82) >>>> =A0 =A0 =A0 =A0at >>>> org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBrok= er.java:77) >>>> =A0 =A0 =A0 =A0at >>>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.jav= a:82) >>>> -- >>>> View this message in context: >>>> http://old.nabble.com/Set-ClientID---InvalidClientIDException-tp291729= 04p29181951.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---Invali= dClientIDException-tp29172904p29182299.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > --=20 http://blog.garytully.com Open Source Integration http://fusesource.com