org.jboss.messaging.core.server.cluster.impl
Class BroadcastGroupImpl

java.lang.Object
  extended by 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
 
Method Summary
 void activate()
           
 void addConnectorPair(Pair<TransportConfiguration,TransportConfiguration> connectorPair)
           
 void broadcastConnectors()
           
 java.lang.String getName()
           
 boolean isStarted()
           
 void removeConnectorPair(Pair<TransportConfiguration,TransportConfiguration> connectorPair)
           
 void run()
           
 void setScheduledFuture(java.util.concurrent.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(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
Method Detail

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.