From activemq-dev-return-657-apmail-geronimo-activemq-dev-archive=geronimo.apache.org@geronimo.apache.org Thu Apr 06 15:44:42 2006 Return-Path: Delivered-To: apmail-geronimo-activemq-dev-archive@www.apache.org Received: (qmail 90621 invoked from network); 6 Apr 2006 15:44:38 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 6 Apr 2006 15:44:38 -0000 Received: (qmail 21289 invoked by uid 500); 6 Apr 2006 15:44:32 -0000 Delivered-To: apmail-geronimo-activemq-dev-archive@geronimo.apache.org Received: (qmail 21215 invoked by uid 500); 6 Apr 2006 15:44:32 -0000 Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-dev@geronimo.apache.org Received: (qmail 21201 invoked by uid 99); 6 Apr 2006 15:44:32 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Apr 2006 08:44:32 -0700 X-ASF-Spam-Status: No, hits=-15.0 required=10.0 tests=ENV_AND_HDR_SPF_MATCH,HTML_MESSAGE,SPF_PASS,USER_IN_DEF_SPF_WL X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: domain of fanli@amazon.com designates 207.171.160.37 as permitted sender) Received: from [207.171.160.37] (HELO smtp-out-2001.amazon.com) (207.171.160.37) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Apr 2006 08:44:31 -0700 X-Amazon-Corporate-Relay: smtp-out-2001.iad2.amazon.com X-AMAZON-TRACK: Received: from smtp-in-2004.iad2.amazon.com by smtp-out-2001.amazon.com with ESMTP (peer crosscheck: smtp-in-2004.iad2.amazon.com) Received: from exchg-sea3-02.ant.amazon.com (exchg-sea3-02.sea3.amazon.com [172.22.1.33]) by smtp-in-2004.iad2.amazon.com (8.12.10/8.12.10) with ESMTP id k36FiAiL004693 for ; Thu, 6 Apr 2006 15:44:10 GMT X-MimeOLE: Produced By Microsoft Exchange V6.5 Content-class: urn:content-classes:message MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----_=_NextPart_001_01C65990.F23DE52E" Subject: FW: InstanceAlreadyExistsException when creating Connections without start them Date: Thu, 6 Apr 2006 08:44:10 -0700 Message-ID: <2A91A89941BD0B4CA56892C3806B3C0C6EF42D@exchg-sea3-02.ant.amazon.com> X-MS-Has-Attach: X-MS-TNEF-Correlator: Thread-Topic: InstanceAlreadyExistsException when creating Connections without start them Thread-Index: AcZZJbvyScZdTFfCTwmr5OyM0fPnyAAasoTw From: "Li, Fan" To: X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N ------_=_NextPart_001_01C65990.F23DE52E Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable This problem stops to appear if I change the variable nextConnectionId = from long to static long, since it now generate different names for each = Connection it tries to register with the MBeanServer. Fan > ______________________________________________=20 > From: Li, Fan =20 > Sent: Wednesday, April 05, 2006 7:57 PM > To: 'activemq-dev@geronimo.apache.org' > Subject: InstanceAlreadyExistsException when creating Connections = without start them >=20 > Hi: >=20 > I am doing a test where I am creating a number of TopicConnections on = different TCP port on my machine, in particular I am using the = TransportConnector URIs: "tcp://localhost:61616", = "tcp://localhost:61626", "tcp://localhost:61636" and = "tcp://localhost:61646". I have started a BrokerService with these four = TransportConnectors and I have created four TCP TopicConnections without = starting any of them, as a result I am getting = InstanceAlreadyExistsException from the registerMBean() method of = ManagedTransportConnection class, with the stack trace similar to: >=20 > 2006-04-05 18:35:53,474 [127.0.0.1:61616] WARN ActiveMQConnection = - Async exception with no exception listener: = java.net.SocketException: Connection reset > java.net.SocketException: Connection reset > at java.net.SocketInputStream.read(SocketInputStream.java:168) > at = org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuffered= InputStream.java:48) > at = org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuffered= InputStream.java:55) > at java.io.DataInputStream.readInt(DataInputStream.java:353) > at = org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java= :270) > at = org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:135)= > at java.lang.Thread.run(Thread.java:595) > 2006-04-05 18:35:53,477 [mazon.com:61616] ERROR TransportConnector = - Could not accept connection: java.io.IOException: = org.apache.activemq:BrokerName=3Dlocalhost,Type=3DConnection,Connection=3D= 1 > java.io.IOException: = org.apache.activemq:BrokerName=3Dlocalhost,Type=3DConnection,Connection=3D= 1 > at = org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.jav= a:36) > at = org.apache.activemq.broker.jmx.ManagedTransportConnection.registerMBean(M= anagedTransportConnection.java:98) > at = org.apache.activemq.broker.jmx.ManagedTransportConnection.setConnectionId= (ManagedTransportConnection.java:78) > at = org.apache.activemq.broker.jmx.ManagedTransportConnection.(ManagedT= ransportConnection.java:57) > at = org.apache.activemq.broker.jmx.ManagedTransportConnector.createConnection= (ManagedTransportConnector.java:60) > at = org.apache.activemq.broker.TransportConnector$1.onAccept(TransportConnect= or.java:135) > at = org.apache.activemq.transport.tcp.TcpTransportServer.run(TcpTransportServ= er.java:137) > at java.lang.Thread.run(Thread.java:595) > Caused by: javax.management.InstanceAlreadyExistsException: = org.apache.activemq:BrokerName=3Dlocalhost,Type=3DConnection,Connection=3D= 1 > at = com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.java= :452) > at = com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(= DefaultMBeanServerInterceptor.java:1410) > at = com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(Defa= ultMBeanServerInterceptor.java:936) > at = com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(Defau= ltMBeanServerInterceptor.java:337) > at = com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:= 497) > at = org.apache.activemq.broker.jmx.ManagedTransportConnection.registerMBean(M= anagedTransportConnection.java:95) > ... 6 more >=20 > Is it required in ActiveMQ to start a Connection right after its = creation? It seems all instances of ManagedTransportConnector for a = particular BrokerService share the same MBeanServer. When I run debugger = on the registerMBean() method that throws the exception, the objects it = tries to register with the MBeanServer appears to be different, but the = name it tries to register them under seems to be the same = "org.apache.activemq:BrokerName=3Dlocalhost,Connection=3D1,Type=3DConnect= ion". Do anyone know what might be the cause of this? >=20 > Thanks > Fan >=20 >=20 ------_=_NextPart_001_01C65990.F23DE52E--