Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4B347C54D for ; Wed, 7 Jan 2015 19:00:34 +0000 (UTC) Received: (qmail 59628 invoked by uid 500); 7 Jan 2015 19:00:35 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 59560 invoked by uid 500); 7 Jan 2015 19:00:35 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 59548 invoked by uid 99); 7 Jan 2015 19:00:35 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Jan 2015 19:00:35 +0000 Date: Wed, 7 Jan 2015 19:00:35 +0000 (UTC) From: =?utf-8?Q?Rodrigo_dos_Santos_C=C3=B4rtes_=28JIRA=29?= To: dev@activemq.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (AMQ-4097) Broker-to-Broker Reconnect fails wrongly due to duplicate name MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-4097?page=3Dcom.atlassian.j= ira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D142680= 16#comment-14268016 ]=20 Rodrigo dos Santos C=C3=B4rtes commented on AMQ-4097: ------------------------------------------------ Hi Ron, What about the "allowLinkStealing" option (recently added) for the Transpor= tConnector? Don't you think it can solve this problem? Thanks. > Broker-to-Broker Reconnect fails wrongly due to duplicate name > -------------------------------------------------------------- > > Key: AMQ-4097 > URL: https://issues.apache.org/jira/browse/AMQ-4097 > Project: ActiveMQ > Issue Type: Bug > Affects Versions: 5.7.0 > Environment: A central broker to which a lot (50+) of external br= okers connect with a duplex bridge. A special routing/firewall is used whic= h can affect timing but not order of TCP packets. This can be simulated by = using socat. > Actually we are using 5.7-SNAPSHOT of 2012-08-31. > Reporter: Ron Koerner > > The situation is as follows: > - an external broker A connects > - time passes > - a lot of external brokers disconnect including A > - A reconnects (as well as all the other external brokers) > - wrong message about duplicate name is generated > In the log it looks like this: > {code} > 2012-10-08 17:11:19,835 INFO .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#278 and tcp:///127.0.0.1:54191(cbox-56BU90244= 2) has been established. [StartLocalBridge: localBroker=3Dvm://c04ptec#278] > ... > ... a lot more of the following with different ports > 2012-10-08 17:37:01,958 WARN .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#278 and tcp:///127.0.0.1:54191 shutdown due t= o a remote error: java.io.EOFException [ActiveMQ NIO Worker 193] > ... more of these > 2012-10-08 17:37:03,438 INFO emq.broker.TransportConnection - Started re= sponder end of duplex bridge cBox 56BU902442 to cBox Proxy@ID:P013SPWMK1WN-= 39320-1349704902319-0:1 [ActiveMQ NIO Worker 215] > ... > 2012-10-08 17:37:03,922 WARN emq.broker.TransportConnection - Failed to = add Connection ID:c04ptec-51799-1349706422094-242:2, reason: javax.jms.Inva= lidClientIDException: Broker: c04ptec - Client: cBox 56BU902442 to cBox Pro= xy_cbox-56BU902442_inbound_c04ptec already connected from vm://c04ptec#278 = [StartLocalBridge: localBroker=3Dvm://c04ptec#478] > 2012-10-08 17:37:03,923 INFO .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#478 and tcp:///127.0.0.1:56529 shutdown due t= o a local error: javax.jms.InvalidClientIDException: Broker: c04ptec - Clie= nt: cBox 56BU902442 to cBox Proxy_cbox-56BU902442_inbound_c04ptec already c= onnected from vm://c04ptec#278 [StartLocalBridge: localBroker=3Dvm://c04pte= c#478] > ... > 2012-10-08 17:37:04,036 INFO .DemandForwardingBridgeSupport - c04ptec br= idge to cbox-56BU902442 stopped [ActiveMQ Task-182] > ... > 2012-10-08 17:37:06,540 INFO emq.broker.TransportConnection - Started re= sponder end of duplex bridge cBox 56BU902442 to cBox Proxy@ID:P013SPWMK1WN-= 39320-1349704902319-0:1 [ActiveMQ NIO Worker 207] > ... > 2012-10-08 17:37:06,548 WARN emq.broker.TransportConnection - Failed to = add Connection ID:c04ptec-51799-1349706422094-292:1, reason: javax.jms.Inva= lidClientIDException: Broker: c04ptec - Client: cBox 56BU902442 to cBox Pro= xy_cbox-56BU902442_inbound_c04ptec already connected from vm://c04ptec#278 = [StartLocalBridge: localBroker=3Dvm://c04ptec#570] > 2012-10-08 17:37:06,548 INFO .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#570 and tcp:///127.0.0.1:56576 shutdown due t= o a local error: javax.jms.InvalidClientIDException: Broker: c04ptec - Clie= nt: cBox 56BU902442 to cBox Proxy_cbox-56BU902442_inbound_c04ptec already c= onnected from vm://c04ptec#278 [StartLocalBridge: localBroker=3Dvm://c04pte= c#570] > ... > 2012-10-08 17:37:06,559 INFO .DemandForwardingBridgeSupport - c04ptec br= idge to cbox-56BU902442 stopped [ActiveMQ Task-204] > ... > 2012-10-08 17:37:24,417 INFO .DemandForwardingBridgeSupport - c04ptec br= idge to cbox-56BU902442 stopped [ActiveMQ Task-73] > ... > 2012-10-08 17:37:25,103 INFO emq.broker.TransportConnection - Started re= sponder end of duplex bridge cBox 56BU902442 to cBox Proxy@ID:P013SPWMK1WN-= 39320-1349704902319-0:1 [ActiveMQ NIO Worker 268] > ... > 2012-10-08 17:37:29,110 INFO .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#594 and tcp:///127.0.0.1:56656(cbox-56BU90244= 2) has been established. [StartLocalBridge: localBroker=3Dvm://c04ptec#594] > ... > 2012-10-08 17:37:59,669 WARN .DemandForwardingBridgeSupport - Network co= nnection between vm://c04ptec#594 and tcp:///127.0.0.1:56656(cbox-56BU90244= 2) was interrupted during establishment. [StartLocalBridge: localBroker=3Dv= m://c04ptec#594] > ... > 2012-10-08 17:38:09,005 INFO .DemandForwardingBridgeSupport - c04ptec br= idge to cbox-56BU902442 stopped [ActiveMQ Task-228] > ... > 2012-10-08 17:38:18,681 INFO emq.broker.TransportConnection - Started re= sponder end of duplex bridge cBox 56BU902442 to cBox Proxy@ID:P013SPWMK1WN-= 39320-1349704902319-0:1 [ActiveMQ NIO Worker 292] > 2012-10-08 17:38:18,681 WARN emq.broker.TransportConnection - Failed to = add Connection ID:P013SPWMK1WN-39320-1349704902319-152:1, reason: javax.jms= .InvalidClientIDException: Broker: c04ptec - Client: cBox 56BU902442 to cBo= x Proxy_cbox-56BU902442_outbound already connected from vm://c04ptec#594 [A= ctiveMQ NIO Worker 292] > 2012-10-08 17:38:18,682 WARN er.TransportConnection.Service - Async erro= r occurred: javax.jms.InvalidClientIDException: Broker: c04ptec - Client: c= Box 56BU902442 to cBox Proxy_cbox-56BU902442_outbound already connected fro= m vm://c04ptec#594 [ActiveMQ NIO Worker 292] > javax.jms.InvalidClientIDException: Broker: c04ptec - Client: cBox 56BU90= 2442 to cBox Proxy_cbox-56BU902442_outbound already connected from vm://c04= ptec#594 > at org.apache.activemq.broker.region.RegionBroker.addConnection(R= egionBroker.java:222) ~[activemq-core-5.7-SNAPSHOT.jar:5.7-SNAPSHOT] > {code} > This repeats until the external broker is stopped and started manually. > I assume there is a race condition which shows up under high load prevent= ing the information about the disconnected client to be removed before the = same client reconnects. -- This message was sent by Atlassian JIRA (v6.3.4#6332)