org.jboss.messaging.core.server.cluster.impl
Class BroadcastGroupImpl
java.lang.Object
org.jboss.messaging.core.server.cluster.impl.BroadcastGroupImpl
- All Implemented Interfaces:
- java.lang.Runnable, BroadcastGroup, MessagingComponent
public class BroadcastGroupImpl
- extends java.lang.Object
- implements BroadcastGroup, java.lang.Runnable
A BroadcastGroupImpl
- Author:
- Tim Fox
Created 15 Nov 2008 09:45:32
Constructor Summary |
BroadcastGroupImpl(java.lang.String nodeID,
java.lang.String name,
java.net.InetAddress localAddress,
int localPort,
java.net.InetAddress groupAddress,
int groupPort,
boolean active)
Broadcast group is bound locally to the wildcard address |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BroadcastGroupImpl
public BroadcastGroupImpl(java.lang.String nodeID,
java.lang.String name,
java.net.InetAddress localAddress,
int localPort,
java.net.InetAddress groupAddress,
int groupPort,
boolean active)
throws java.lang.Exception
- Broadcast group is bound locally to the wildcard address
- Throws:
java.lang.Exception
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface MessagingComponent
- Throws:
java.lang.Exception
stop
public void stop()
- Specified by:
stop
in interface MessagingComponent
isStarted
public boolean isStarted()
- Specified by:
isStarted
in interface MessagingComponent
getName
public java.lang.String getName()
- Specified by:
getName
in interface BroadcastGroup
addConnectorPair
public void addConnectorPair(Pair<TransportConfiguration,TransportConfiguration> connectorPair)
- Specified by:
addConnectorPair
in interface BroadcastGroup
removeConnectorPair
public void removeConnectorPair(Pair<TransportConfiguration,TransportConfiguration> connectorPair)
- Specified by:
removeConnectorPair
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 java.lang.Exception
- Specified by:
broadcastConnectors
in interface BroadcastGroup
- Throws:
java.lang.Exception
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
setScheduledFuture
public void setScheduledFuture(java.util.concurrent.ScheduledFuture<?> future)
Copyright © 2006 JBoss Inc. All Rights Reserved.