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 and Description |
---|
BroadcastGroupImpl(NodeManager nodeManager,
String name,
long broadCastPeriod,
ScheduledExecutorService scheduledExecutor,
BroadcastEndpointFactory endpointFactory) |
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() |
public BroadcastGroupImpl(NodeManager nodeManager, String name, long broadCastPeriod, ScheduledExecutorService scheduledExecutor, BroadcastEndpointFactory endpointFactory) throws Exception
Exception
public void setNotificationService(NotificationService notificationService)
setNotificationService
in interface BroadcastGroup
public void start() throws Exception
start
in interface ActiveMQComponent
Exception
public void stop()
stop
in interface ActiveMQComponent
public boolean isStarted()
isStarted
in interface ActiveMQComponent
public String getName()
getName
in interface BroadcastGroup
public void addConnector(TransportConfiguration tcConfig)
addConnector
in interface BroadcastGroup
public void removeConnector(TransportConfiguration tcConfig)
removeConnector
in interface BroadcastGroup
public int size()
size
in interface BroadcastGroup
public void broadcastConnectors() throws Exception
broadcastConnectors
in interface BroadcastGroup
Exception
Copyright © 2020 JBoss by Red Hat. All rights reserved.