org.hornetq.core.cluster.impl

Class DiscoveryGroupImpl

java.lang.Object

org.hornetq.core.cluster.impl.DiscoveryGroupImpl

All Implemented Interfaces:

Runnable, DiscoveryGroup

public class DiscoveryGroupImpl
extends Object
implements Runnable, DiscoveryGroup

A DiscoveryGroupImpl

Author:

Tim Fox Created 17 Nov 2008 13:21:45

Constructor Summary

Constructors

Constructor and Description
DiscoveryGroupImpl(String nodeID, String name, InetAddress localBindAddress, InetAddress groupAddress, int groupPort, long timeout)

Method Summary

Methods

Modifier and Type	Method and Description
List<DiscoveryEntry>	getDiscoveryEntries()
String	getName()
boolean	isStarted()
void	registerListener(DiscoveryListener listener)
void	run()
void	setNotificationService(NotificationService notificationService)
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

Constructor Detail

DiscoveryGroupImpl

public DiscoveryGroupImpl(String nodeID,
                  String name,
                  InetAddress localBindAddress,
                  InetAddress groupAddress,
                  int groupPort,
                  long timeout)
                   throws Exception

Throws:

Exception

Method Detail

setNotificationService

public void setNotificationService(NotificationService notificationService)

Specified by:

setNotificationService in interface DiscoveryGroup

start

public void start()
           throws Exception

Specified by:

start in interface DiscoveryGroup

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface DiscoveryGroup

isStarted

public boolean isStarted()

Specified by:

isStarted in interface DiscoveryGroup

getName

public String getName()

Specified by:

getName in interface DiscoveryGroup

getDiscoveryEntries

public List<DiscoveryEntry> getDiscoveryEntries()

Specified by:

getDiscoveryEntries in interface DiscoveryGroup

waitForBroadcast

public boolean waitForBroadcast(long timeout)

Specified by:

waitForBroadcast in interface DiscoveryGroup

run

public void run()

Specified by:

run in interface Runnable

registerListener

public void registerListener(DiscoveryListener listener)

Specified by:

registerListener in interface DiscoveryGroup

unregisterListener

public void unregisterListener(DiscoveryListener listener)

Specified by:

unregisterListener in interface DiscoveryGroup