public final class LocalGroupingHandler extends Object implements GroupingHandler
Constructor and Description |
---|
LocalGroupingHandler(ExecutorFactory executorFactory,
ScheduledExecutorService scheduledExecutor,
ManagementService managementService,
SimpleString name,
SimpleString address,
StorageManager storageManager,
long timeout,
long groupTimeout,
long reaperPeriod) |
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() |
public LocalGroupingHandler(ExecutorFactory executorFactory, ScheduledExecutorService scheduledExecutor, ManagementService managementService, SimpleString name, SimpleString address, StorageManager storageManager, long timeout, long groupTimeout, long reaperPeriod)
public SimpleString getName()
getName
in interface GroupingHandler
public Response propose(Proposal proposal) throws Exception
propose
in interface GroupingHandler
Exception
public void proposed(Response response) throws Exception
proposed
in interface GroupingHandler
Exception
public void remove(SimpleString groupid, SimpleString clusterName, int distance)
remove
in interface GroupingHandler
public void send(Response response, int distance) throws Exception
send
in interface GroupingHandler
Exception
public Response receive(Proposal proposal, int distance) throws Exception
receive
in interface GroupingHandler
Exception
public void addGroupBinding(GroupBinding groupBinding)
addGroupBinding
in interface GroupingHandler
public Response getProposal(SimpleString fullID)
getProposal
in interface GroupingHandler
public void awaitBindings() throws Exception
awaitBindings
in interface GroupingHandler
Exception
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public boolean isStarted()
isStarted
in interface HornetQComponent
Copyright © 2014 JBoss by Red Hat. All Rights Reserved.