org.hornetq.core.server.group.impl

Class LocalGroupingHandler

java.lang.Object

org.hornetq.core.server.group.impl.LocalGroupingHandler

All Implemented Interfaces:

GroupingHandler, HornetQComponent, NotificationListener

public final class LocalGroupingHandler
extends Object
implements GroupingHandler

A Local Grouping handler. All the Remote handlers will talk with us

Author:

Andy Taylor

Constructor Summary

Constructors

Constructor and Description
LocalGroupingHandler(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, ManagementService managementService, SimpleString name, SimpleString address, StorageManager storageManager, long timeout, long groupTimeout, long reaperPeriod)

Method Summary

Modifier and Type	Method and Description
void	addGroupBinding(GroupBinding groupBinding)
void	awaitBindings()
SimpleString	getName()
Response	getProposal(SimpleString fullID)
boolean	isStarted()
void	onNotification(Notification notification)
Response	propose(Proposal proposal)
void	proposed(Response response)
Response	receive(Proposal proposal, int distance)
void	remove(SimpleString groupid, SimpleString clusterName, int distance)
void	send(Response response, int distance)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalGroupingHandler

public LocalGroupingHandler(ExecutorFactory executorFactory,
                            ScheduledExecutorService scheduledExecutor,
                            ManagementService managementService,
                            SimpleString name,
                            SimpleString address,
                            StorageManager storageManager,
                            long timeout,
                            long groupTimeout,
                            long reaperPeriod)

Method Detail

getName

public SimpleString getName()

Specified by:

getName in interface GroupingHandler

propose

public Response propose(Proposal proposal)
                 throws Exception

Specified by:

propose in interface GroupingHandler

Throws:

Exception

proposed

public void proposed(Response response)
              throws Exception

Specified by:

proposed in interface GroupingHandler

Throws:

Exception

remove

public void remove(SimpleString groupid,
                   SimpleString clusterName,
                   int distance)

Specified by:

remove in interface GroupingHandler

send

public void send(Response response,
                 int distance)
          throws Exception

Specified by:

send in interface GroupingHandler

Throws:

Exception

receive

public Response receive(Proposal proposal,
                        int distance)
                 throws Exception

Specified by:

receive in interface GroupingHandler

Throws:

Exception

addGroupBinding

public void addGroupBinding(GroupBinding groupBinding)

Specified by:

addGroupBinding in interface GroupingHandler

getProposal

public Response getProposal(SimpleString fullID)

Specified by:

getProposal in interface GroupingHandler

awaitBindings

public void awaitBindings()
                   throws Exception

Specified by:

awaitBindings in interface GroupingHandler

Throws:

Exception

onNotification

public void onNotification(Notification notification)

Specified by:

onNotification in interface NotificationListener

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent