You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2008/04/02 15:56:28 UTC
svn commit: r643908 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
Author: chirino
Date: Wed Apr 2 06:56:26 2008
New Revision: 643908
URL: http://svn.apache.org/viewvc?rev=643908&view=rev
Log:
Add some info logging so you can check to see if the discovery agent is generating duplicate onServiceAdd events
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java?rev=643908&r1=643907&r2=643908&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java Wed Apr 2 06:56:26 2008
@@ -73,7 +73,11 @@
return;
}
// Should we try to connect to that URI?
- if (bridges.containsKey(uri) || localURI.equals(uri) || (connectionFilter != null && !connectionFilter.connectTo(uri))) {
+ if( bridges.containsKey(uri) ) {
+ LOG.debug("Discovery agent generated a duplicate onServiceAdd event for: "+uri );
+ return;
+ }
+ if ( localURI.equals(uri) || (connectionFilter != null && !connectionFilter.connectTo(uri))) {
return;
}
URI connectUri = uri;