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

Interface GroupingHandler

All Superinterfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, org.apache.activemq.artemis.core.server.management.NotificationListener

All Known Implementing Classes:

GroupHandlingAbstract, LocalGroupingHandler, RemoteGroupingHandler

public interface GroupingHandler
extends org.apache.activemq.artemis.core.server.management.NotificationListener, org.apache.activemq.artemis.core.server.ActiveMQComponent

Method Summary

Modifier and Type	Method and Description
void	addGroupBinding(GroupBinding groupBinding)
void	addListener(UnproposalListener listener)
void	awaitBindings()
void	forceRemove(org.apache.activemq.artemis.api.core.SimpleString groupid, org.apache.activemq.artemis.api.core.SimpleString clusterName) this will force a removal of the group everywhere with an unproposal (dinstance=0).
org.apache.activemq.artemis.api.core.SimpleString	getName()
Response	getProposal(org.apache.activemq.artemis.api.core.SimpleString fullID, boolean touchTime)
Response	propose(Proposal proposal)
void	proposed(Response response)
Response	receive(Proposal proposal, int distance)
void	remove(org.apache.activemq.artemis.api.core.SimpleString groupid, org.apache.activemq.artemis.api.core.SimpleString clusterName)
void	remove(org.apache.activemq.artemis.api.core.SimpleString groupid, org.apache.activemq.artemis.api.core.SimpleString clusterName, int distance)
void	resendPending()
void	sendProposalResponse(Response response, int distance)

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

onNotification

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

isStarted, start, stop

Method Detail

addListener

void addListener(UnproposalListener listener)

getName

org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.SimpleString fullID,
                     boolean touchTime)

awaitBindings

void awaitBindings()
            throws Exception

Throws:

Exception

forceRemove

void forceRemove(org.apache.activemq.artemis.api.core.SimpleString groupid,
                 org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.SimpleString groupid,
            org.apache.activemq.artemis.api.core.SimpleString clusterName)
     throws Exception

Throws:

Exception

remove

void remove(org.apache.activemq.artemis.api.core.SimpleString groupid,
            org.apache.activemq.artemis.api.core.SimpleString clusterName,
            int distance)
     throws Exception

Throws:

Exception