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 2006/10/15 17:52:15 UTC
svn commit: r464216 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
Author: chirino
Date: Sun Oct 15 08:52:11 2006
New Revision: 464216
URL: http://svn.apache.org/viewvc?view=rev&rev=464216
Log:
Copy the configured broker info too so that the brokerName is set on the created discovery agent.
This fixes the WARN message that was being produced on startup.
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java?view=diff&rev=464216&r1=464215&r2=464216
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java Sun Oct 15 08:52:11 2006
@@ -105,6 +105,7 @@
rc.setDiscoveryUri(discoveryUri);
rc.setName(name);
rc.setDisableAsyncDispatch(disableAsyncDispatch);
+ rc.setBrokerInfo(brokerInfo);
return rc;
}
@@ -212,6 +213,7 @@
getServer().start();
DiscoveryAgent da = getDiscoveryAgent();
if( da!=null ) {
+ da.setBrokerName(getBrokerInfo().getBrokerName());
da.registerService(getConnectUri().toString());
da.start();
}