org.hornetq.core.server.cluster.impl

Class BroadcastGroupImpl

java.lang.Object

org.hornetq.core.server.cluster.impl.BroadcastGroupImpl

All Implemented Interfaces:

Runnable, BroadcastGroup, HornetQComponent

public class BroadcastGroupImpl
extends Object
implements BroadcastGroup, Runnable

A BroadcastGroupImpl

Author:

Tim Fox Created 15 Nov 2008 09:45:32

Constructor Summary

Constructors

Constructor and Description
BroadcastGroupImpl(String nodeID, String name, InetAddress localAddress, int localPort, InetAddress groupAddress, int groupPort, boolean active) Broadcast group is bound locally to the wildcard address

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
void	addConnector(TransportConfiguration tcConfig)
void	broadcastConnectors()
String	getName()
boolean	isStarted()
void	removeConnector(TransportConfiguration tcConfig)
void	run()
void	setNotificationService(NotificationService notificationService)
void	setScheduledFuture(ScheduledFuture<?> future)
int	size()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastGroupImpl

public BroadcastGroupImpl(String nodeID,
                  String name,
                  InetAddress localAddress,
                  int localPort,
                  InetAddress groupAddress,
                  int groupPort,
                  boolean active)
                   throws Exception

Broadcast group is bound locally to the wildcard address

Throws:

Exception

Method Detail

setNotificationService

public void setNotificationService(NotificationService notificationService)

Specified by:

setNotificationService in interface BroadcastGroup

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface HornetQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getName

public String getName()

Specified by:

getName in interface BroadcastGroup

addConnector

public void addConnector(TransportConfiguration tcConfig)

Specified by:

addConnector in interface BroadcastGroup

removeConnector

public void removeConnector(TransportConfiguration tcConfig)

Specified by:

removeConnector in interface BroadcastGroup

size

public int size()

Specified by:

size in interface BroadcastGroup

activate

public void activate()

Specified by:

activate in interface BroadcastGroup

broadcastConnectors

public void broadcastConnectors()
                         throws Exception

Specified by:

broadcastConnectors in interface BroadcastGroup

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

setScheduledFuture

public void setScheduledFuture(ScheduledFuture<?> future)