Hi all,

I'm trying to create a network of two brokers, for in case one broker
quits, the other takes over. When I add a scheduled message to broker1,
and I stop it, the scheduled messages just stop, and broker2 does nothing.
I expect that broker2 takes over sending the scheduled message (and any
non-scheduled messages). What is wrong?

We create everything by code. This is how I add broker1 to broker2 and the
reverse, maybe I should do more. Argument otherBrokerName  =
tcp://localhost:8001 or :8002 .

public void addBroker(String otherBrokerName) throws Exception {
        DiscoveryNetworkConnector discoveryNetworkConnector = new
DiscoveryNetworkConnector();
        SimpleDiscoveryAgent simpleDiscoveryAgent = new SimpleDiscoveryAgent();
        simpleDiscoveryAgent
                                .setServices(new URI[] { new 
URI(otherBrokerName) });
                
discoveryNetworkConnector.setDiscoveryAgent(simpleDiscoveryAgent);
        discoveryNetworkConnector.setDuplex(true);
        discoveryNetworkConnector.setName(otherBrokerName);
        discoveryNetworkConnector.setNetworkTTL(100);
        broker.addNetworkConnector(discoveryNetworkConnector);
        discoveryNetworkConnector.start();
        }

Is there any specific configuration that I miss?

Thanks a lot!
Niels



Reply via email to