Package org.apache.activemq.artemis.core.cluster

Class DiscoveryGroup

java.lang.Object

org.apache.activemq.artemis.core.cluster.DiscoveryGroup

All Implemented Interfaces:

ActiveMQComponent

public final class DiscoveryGroup
extends Object
implements ActiveMQComponent

This class is used to search for members on the cluster through the opaque interface BroadcastEndpoint.

There are two current implementations, and that's probably all we will ever need.

We will probably keep both interfaces for a while as UDP is a simple solution requiring no extra dependencies which is suitable for users looking for embedded solutions.

Constructor Summary

Constructors

Constructor	Description
DiscoveryGroup(String nodeID, String name, long timeout, long stoppingTimeout, BroadcastEndpointFactory endpointFactory, NotificationService service)	This is the main constructor, intended to be used

Method Summary

Modifier and Type	Method	Description
List<DiscoveryEntry>	getDiscoveryEntries()
String	getName()
void	internalRunning()	This will start the DiscoveryRunnable and run it directly.
boolean	isStarted()
void	registerListener(DiscoveryListener listener)
void	start()
void	stop()
void	unregisterListener(DiscoveryListener listener)
boolean	waitForBroadcast(long timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Constructor Details

DiscoveryGroup

public DiscoveryGroup(String nodeID,
 String name,
 long timeout,
 long stoppingTimeout,
 BroadcastEndpointFactory endpointFactory,
 NotificationService service)
               throws Exception

This is the main constructor, intended to be used

Throws:

Exception

Method Details

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

internalRunning

public void internalRunning()
                     throws Exception

This will start the DiscoveryRunnable and run it directly. This is useful for a test process where we need this execution blocking a thread.

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface ActiveMQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getName

public String getName()

getDiscoveryEntries

public List<DiscoveryEntry> getDiscoveryEntries()

waitForBroadcast

public boolean waitForBroadcast(long timeout)

registerListener

public void registerListener(DiscoveryListener listener)

unregisterListener

public void unregisterListener(DiscoveryListener listener)