AMQ 4.1.1 and TransportConnector brokerName

[Manuel Teira <mt...@tid.es>]

Hello.

My aim is to be able to have different clusters (JDBC master-slave) 
running in the same local network. I also want to be able to discover 
the running nodes from the clients, and so I was using a discoverUri 
(multicast://default) in the TransportConnector and the proper 
configuration for the clients. But to be able to isolate the different 
clusters, I think that I need to use different discoveryUris.

The first question is about the meaning of that uri multicast://default. 
Is that the same than using:

public static final String 
DEFAULT_DISCOVERY_URI_STRING="multicast://239.255.2.3:6155";

?

I've also seen that there's a property in the MulticastDiscoveryAgent 
called group. Its default value is 'default', is that related with the 
'default' token in the URI?

I wonder if URIs like multicast://<token> using different tokens for the 
different clusters should be enough to discriminate them. This is 
related with the following question:


Looking at the source code, it seems that the multicast code  is using 
the brokerName of the TransportConnector to be able to discriminate 
different clusters, as the packet payload has something like:

           String payload=getType();
            payload+=started.get()?ALIVE:DEAD;
            payload+=DELIMITER+brokerName+DELIMITER;
            payload+=selfService;

in org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent

But while starting; I get a warning that seems to be written from 
MulticastDiscoveryAgent.start()

            if (brokerName == null || brokerName.length()==0){
                log.warn("brokerName not set");
            }

Looking a little more in the code, it seems that the brokerName should 
be set by org.apache.activemq.broker.TransportConnector, before starting 
the DiscoveryAgent, its start() method says:

        if( da!=null ) {
            da.setBrokerName(getBrokerInfo().getBrokerName());
            da.registerService(getConnectUri().toString());
            da.start();
        }

So, the brokerName is the one in the BrokerInfo private instance of the 
TransportConnector, that is set using 
TransportConnector.setBrokername(String brokerName)

This is what I have in the xml configuration file:

<transportConnector brokerName="test" name="default" 
uri="tcp://localhost:61625" discoveryUri="multicast://224.1.2.3:6255"/>

In the activeMQ log, I see how spring is aware of the brokerName 
property, and it seems to set it:


[DEBUG][2007-06-06 
17:03:13,266][main][org.springframework.beans.CachedIntrospectionResults] 
Caching PropertyDescriptors for class 
[org.apache.activemq.broker.TransportConnector]
...

[DEBUG][2007-06-06 
17:03:13,267][main][org.springframework.beans.CachedIntrospectionResults] 
Found bean property 'brokerName' of type [java.lang.String]
...

[DEBUG][2007-06-06 
15:37:25,748][main][org.springframework.beans.BeanWrapperImpl] About to 
invoke write method [public void 
org.apache.activemq.broker.TransportConnector.setBrokerName(java.lang.String)] 
on object of class [org.apache.activemq.broker.TransportConnector]
[DEBUG][2007-06-06 
15:37:25,748][main][org.springframework.beans.BeanWrapperImpl] Invoked 
write method [public void 
org.apache.activemq.broker.TransportConnector.setBrokerName(java.lang.String)] 
with value of type [java.lang.String]

But, anyway, I'm getting multiple warnings like this:


[WARN ][2007-06-06 
15:37:27,459][main][org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent] 
brokerName not set


Perhaps they are from different MulticastDiscoveryAgents than the one 
bound to the TransportConnector?


So, please. Could you explain or direct me to some information source 
where I could learn how to write a proper multicast URI, and what is the 
meaning of its fields?

Thanks a lot.