Package org.apache.activemq.artemis.core.server.group

Interface GroupingHandler

All Superinterfaces:

ActiveMQComponent, NotificationListener

All Known Implementing Classes:

GroupHandlingAbstract, LocalGroupingHandler, RemoteGroupingHandler

public interface GroupingHandler
extends NotificationListener, ActiveMQComponent

Method Summary

Modifier and Type	Method	Description
void	addGroupBinding(GroupBinding groupBinding)
void	addListener(UnproposalListener listener)
void	awaitBindings()
void	forceRemove(SimpleString groupid, SimpleString clusterName)	this will force a removal of the group everywhere with an unproposal (dinstance=0).
SimpleString	getName()
Response	getProposal(SimpleString fullID, boolean touchTime)
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)

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop, isStarted, start, stop

Methods inherited from interface org.apache.activemq.artemis.core.server.management.NotificationListener

onNotification

Method Details

addListener

void addListener(UnproposalListener listener)

getName

SimpleString getName()

resendPending

void resendPending()
            throws Exception

Throws:

Exception

propose

Response propose(Proposal proposal)
          throws Exception

Throws:

Exception

proposed

void proposed(Response response)
       throws Exception

Throws:

Exception

sendProposalResponse

void sendProposalResponse(Response response,
 int distance)
                   throws Exception

Throws:

Exception

receive

Response receive(Proposal proposal,
 int distance)
          throws Exception

Throws:

Exception

addGroupBinding

void addGroupBinding(GroupBinding groupBinding)

getProposal

Response getProposal(SimpleString fullID,
 boolean touchTime)

awaitBindings

void awaitBindings()
            throws Exception

Throws:

Exception

forceRemove

void forceRemove(SimpleString groupid,
 SimpleString clusterName)
          throws Exception

this will force a removal of the group everywhere with an unproposal (dinstance=0). This is for the case where a node goes missing

Throws:

Exception

remove

void remove(SimpleString groupid,
 SimpleString clusterName)
     throws Exception

Throws:

Exception

remove

void remove(SimpleString groupid,
 SimpleString clusterName,
 int distance)
     throws Exception

Throws:

Exception