org.apache.activemq.artemis.core.server.cluster.impl

Class BroadcastGroupImpl

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.impl.BroadcastGroupImpl

All Implemented Interfaces:

Runnable, ActiveMQComponent, BroadcastGroup

public class BroadcastGroupImpl
extends Object
implements BroadcastGroup, Runnable

This class will use the BroadcastEndpoint to send periodical updates on the list for connections used by this server.

This is totally generic to the mechanism used on the transmission. It originally only had UDP but this got refactored into sub classes of BroadcastEndpoint

Constructor Summary

Constructors

Constructor and Description
BroadcastGroupImpl(NodeManager nodeManager, String name, long broadCastPeriod, ScheduledExecutorService scheduledExecutor, BroadcastEndpointFactory endpointFactory)

Method Summary

Modifier and Type	Method and Description
void	addConnector(TransportConfiguration tcConfig)
void	broadcastConnectors()
String	getName()
boolean	isStarted()
void	removeConnector(TransportConfiguration tcConfig)
void	run()
void	setNotificationService(NotificationService notificationService)
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(NodeManager nodeManager,
                          String name,
                          long broadCastPeriod,
                          ScheduledExecutorService scheduledExecutor,
                          BroadcastEndpointFactory endpointFactory)
                   throws Exception

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 ActiveMQComponent

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()

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

broadcastConnectors

public void broadcastConnectors()
                         throws Exception

Specified by:

broadcastConnectors in interface BroadcastGroup

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable