public final class RemoteGroupingHandler extends GroupHandlingAbstract
This will use management notifications to communicate with the node that has the Local Grouping handler to make proposals.
address, executor, managementService
Constructor and Description |
---|
RemoteGroupingHandler(ExecutorFactory executorFactory,
ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout,
long groupTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
addGroupBinding(GroupBinding groupBinding) |
void |
awaitBindings() |
SimpleString |
getName() |
Response |
getProposal(SimpleString fullID,
boolean touchTime) |
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) |
void |
remove(SimpleString groupid,
SimpleString clusterName,
int distance) |
void |
resendPending() |
void |
sendProposalResponse(Response response,
int distance) |
void |
start() |
void |
stop() |
addListener, fireUnproposed, forceRemove, sendUnproposal
public RemoteGroupingHandler(ExecutorFactory executorFactory, ManagementService managementService, SimpleString name, SimpleString address, long timeout, long groupTimeout)
public RemoteGroupingHandler(ManagementService managementService, SimpleString name, SimpleString address, long timeout, long groupTimeout)
public SimpleString getName()
public boolean isStarted()
public void awaitBindings()
public Response getProposal(SimpleString fullID, boolean touchTime)
public void remove(SimpleString groupid, SimpleString clusterName) throws Exception
Exception
public void remove(SimpleString groupid, SimpleString clusterName, int distance) throws Exception
Exception
public void sendProposalResponse(Response response, int distance) throws Exception
Exception
public void addGroupBinding(GroupBinding groupBinding)
public void onNotification(Notification notification)
Copyright © 2017 JBoss by Red Hat. All rights reserved.