Return-Path: 
 <issues-return-4992-apmail-activemq-issues-archive=activemq.apache.org@activemq.apache.org>
X-Original-To: apmail-activemq-issues-archive@minotaur.apache.org
Delivered-To: apmail-activemq-issues-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 6534018CCD
	for <apmail-activemq-issues-archive@minotaur.apache.org>;
 Mon, 11 Jan 2016 13:02:40 +0000 (UTC)
Received: (qmail 11591 invoked by uid 500); 11 Jan 2016 13:02:40 -0000
Delivered-To: apmail-activemq-issues-archive@activemq.apache.org
Received: (qmail 11547 invoked by uid 500); 11 Jan 2016 13:02:40 -0000
Mailing-List: contact issues-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:issues-help@activemq.apache.org>
List-Unsubscribe: <mailto:issues-unsubscribe@activemq.apache.org>
List-Post: <mailto:issues@activemq.apache.org>
List-Id: <issues.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list issues@activemq.apache.org
Received: (qmail 11535 invoked by uid 99); 11 Jan 2016 13:02:40 -0000
Received: from arcas.apache.org (HELO arcas) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jan 2016 13:02:40 +0000
Received: from arcas.apache.org (localhost [127.0.0.1])
	by arcas (Postfix) with ESMTP id C94D82C0453
	for <issues@activemq.apache.org>; Mon, 11 Jan 2016 13:02:39 +0000 (UTC)
Date: Mon, 11 Jan 2016 13:02:39 +0000 (UTC)
From: "Gary Tully (JIRA)" <jira@apache.org>
To: issues@activemq.apache.org
Message-ID: <JIRA.12914299.1447891404000.72429.1452517359820@Atlassian.JIRA>
In-Reply-To: <JIRA.12914299.1447891404000@Atlassian.JIRA>
References: <JIRA.12914299.1447891404000@Atlassian.JIRA>
 <JIRA.12914299.1447891404397@arcas>
Subject: [jira] [Commented] (AMQ-6052) Network of brokers on duplex mode
 reports InstanceAlreadyExistsException on already existing destinations
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394


    [ https://issues.apache.org/jira/browse/AMQ-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091869#comment-15091869 ] 

Gary Tully commented on AMQ-6052:
---------------------------------

[~Altaflux] thanks for the fix and test. I pushed your changes, they look good. Lets track the nightly tests to pick up any possible regressions

> Network of brokers on duplex mode reports InstanceAlreadyExistsException on already existing destinations
> ---------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-6052
>                 URL: https://issues.apache.org/jira/browse/AMQ-6052
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: networkbridge
>    Affects Versions: 5.10.1, 5.12.1, 5.11.3
>         Environment: Linux
>            Reporter: Pablo Lozano
>              Labels: jmx, networkBridge, networkConnector
>         Attachments: AMQ_6052-2.patch, AMQ_6052.patch
>
>
> When using a network of brokers apparently on duplex with destinations which were already created on each MBeanBridgeDestination.onOutboundMessage() and MBeanBridgeDestination.onInboundMessage() the bridge tries to register the MBean of a destination which has already been created.
> Here is a discussion that started but a ticket was not created.
> http://activemq.2283324.n4.nabble.com/Broker-log-full-of-Failed-to-register-queue-messages-td4685241.html
> Although this does not seem to impact the functionality of the application it creates a massive amount of logs as this message repeats for every received message. 
> This are the important bits of my activeMQ configuration:
> {code:xml}
>        <networkConnectors>
>             <networkConnector name="mailSystemConnector" uri="multicast://default" conduitSubscriptions="true" duplex="true" >
>                 <dynamicallyIncludedDestinations>
>                     <queue physicalName="mailsystem.templateprocessor"/>
>                     <queue physicalName="DLQ.mailsystem.templateprocessor"/>
>                 </dynamicallyIncludedDestinations>
>             </networkConnector>
>         </networkConnectors>
>         <destinations>
>             <queue physicalName="SCE"/>
>             <queue physicalName="mailsystem.templateprocessor"/>
>             <queue physicalName="ActiveMQ.DLQ"/>
>         </destinations>
>         <managementContext>
>             <managementContext createConnector="true"
>                                connectorPort="1091"
>                                jmxDomainName="org.apache.activemq"/>
>         </managementContext>
>         <!-- The transport connectors ActiveMQ will listen to -->
>         <transportConnectors>
>             <transportConnector name="openwire nio" uri="nio://0.0.0.0:61616" updateClusterClients="true"
>                                 rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
>             <transportConnector name="openwireDiscovery" uri="tcp://0.0.0.0:0"
>                                 discoveryUri="multicast://default" updateClusterClients="true"
>                                 rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
>             <transportConnector name="stomp" uri="stomp://0.0.0.0:61613" updateClusterClients="true"
>                                 rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
>         </transportConnectors>
> {code}
> And this is the output log generated:
> {noformat}
> 2015-11-18 15:43:10,497 [.69:41090@36731] WARN  MBeanBridgeDestination         - Failed to register queue://mailsystem.templateprocessor
> javax.management.InstanceAlreadyExistsException: org.apache.activemq:brokerName=mailsystemBroker,connector=duplexNetworkConnectors,networkConnectorName=#0,networkBridge=tcp_//10.211.2.69_41090,type=Broker,direction=inbound,destinationType=Queue,destinationName=mailsystem.templateprocessor
>         at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
>         at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
>         at org.apache.activemq.broker.jmx.ManagementContext.registerMBean(ManagementContext.java:380)
>         at org.apache.activemq.broker.jmx.AnnotatedMBean.registerMBean(AnnotatedMBean.java:72)
>         at org.apache.activemq.network.MBeanBridgeDestination.onInboundMessage(MBeanBridgeDestination.java:97)
>         at org.apache.activemq.network.MBeanNetworkListener.onInboundMessage(MBeanNetworkListener.java:115)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceInboundMessage(DemandForwardingBridgeSupport.java:1680)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:649)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport$3.onCommand(DemandForwardingBridgeSupport.java:224)
>         at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>         at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>         at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
>         at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)
>         at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
>         at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
>         at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
>         at java.lang.Thread.run(Thread.java:745)
> {noformat}
> {noformat}
> 		2015-11-18 15:43:09,634 [Broker] Task-16] WARN  MBeanBridgeDestination         - Failed to register queue://mailsystem.templateprocessor
> javax.management.InstanceAlreadyExistsException: org.apache.activemq:brokerName=mailsystemBroker,connector=networkConnectors,networkConnectorName=mailSystemConnector,networkBridge=tcp_//10.211.2.70_36731,type=Broker,direction=outbound,destinationType=Queue,destinationName=mailsystem.templateprocessor
>         at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
>         at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
>         at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
>         at org.apache.activemq.broker.jmx.ManagementContext.registerMBean(ManagementContext.java:380)
>         at org.apache.activemq.broker.jmx.AnnotatedMBean.registerMBean(AnnotatedMBean.java:72)
>         at org.apache.activemq.network.MBeanBridgeDestination.onOutboundMessage(MBeanBridgeDestination.java:72)
>         at org.apache.activemq.network.MBeanNetworkListener.onOutboundMessage(MBeanNetworkListener.java:107)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceOutbound(DemandForwardingBridgeSupport.java:1673)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLocalCommand(DemandForwardingBridgeSupport.java:1035)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:206)
>         at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>         at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>         at org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)
>         at org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)
>         at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)
>         at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
>         at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>         at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1419)
>         at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:938)
>         at org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:984)
>         at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
>         at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:745)
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)