public abstract class GroupHandlingAbstract extends Object implements GroupingHandler
Modifier and Type | Field and Description |
---|---|
protected SimpleString |
address |
protected Executor |
executor |
protected ManagementService |
managementService |
Constructor and Description |
---|
GroupHandlingAbstract(Executor executor,
ManagementService managementService,
SimpleString address) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(UnproposalListener listener) |
protected void |
fireUnproposed(SimpleString groupID) |
void |
forceRemove(SimpleString groupid,
SimpleString clusterName)
this will force a removal of the group everywhere with an unproposal (dinstance=0).
|
protected void |
sendUnproposal(SimpleString groupid,
SimpleString clusterName,
int distance) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addGroupBinding, awaitBindings, getName, getProposal, propose, proposed, receive, remove, remove, resendPending, sendProposalResponse
onNotification
isStarted, start, stop
protected final Executor executor
protected final ManagementService managementService
protected final SimpleString address
public GroupHandlingAbstract(Executor executor, ManagementService managementService, SimpleString address)
public void addListener(UnproposalListener listener)
addListener
in interface GroupingHandler
protected void fireUnproposed(SimpleString groupID)
public void forceRemove(SimpleString groupid, SimpleString clusterName) throws Exception
GroupingHandler
forceRemove
in interface GroupingHandler
Exception
protected void sendUnproposal(SimpleString groupid, SimpleString clusterName, int distance)
Copyright © 2020 JBoss by Red Hat. All rights reserved.