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

Class GroupHandlingAbstract

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

LocalGroupingHandler, RemoteGroupingHandler

public abstract class GroupHandlingAbstract
extends Object
implements GroupingHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.activemq.artemis.api.core.SimpleString	address
protected Executor	executor
protected ManagementService	managementService

Constructor Summary

Constructors

Constructor and Description
GroupHandlingAbstract(Executor executor, ManagementService managementService, org.apache.activemq.artemis.api.core.SimpleString address)

Method Summary

Modifier and Type	Method and Description
void	addListener(UnproposalListener listener)
protected void	fireUnproposed(org.apache.activemq.artemis.api.core.SimpleString groupID)
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).
protected void	sendUnproposal(org.apache.activemq.artemis.api.core.SimpleString groupid, org.apache.activemq.artemis.api.core.SimpleString clusterName, int distance)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.group.GroupingHandler

addGroupBinding, awaitBindings, getName, getProposal, propose, proposed, receive, remove, remove, resendPending, sendProposalResponse

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

Field Detail

executor

protected final Executor executor

managementService

protected final ManagementService managementService

address

protected final org.apache.activemq.artemis.api.core.SimpleString address

Constructor Detail

GroupHandlingAbstract

public GroupHandlingAbstract(Executor executor,
                             ManagementService managementService,
                             org.apache.activemq.artemis.api.core.SimpleString address)

Method Detail

addListener

public void addListener(UnproposalListener listener)

Specified by:

addListener in interface GroupingHandler

fireUnproposed

protected void fireUnproposed(org.apache.activemq.artemis.api.core.SimpleString groupID)

forceRemove

public void forceRemove(org.apache.activemq.artemis.api.core.SimpleString groupid,
                        org.apache.activemq.artemis.api.core.SimpleString clusterName)
                 throws Exception

Description copied from interface: GroupingHandler

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

Specified by:

forceRemove in interface GroupingHandler

Throws:

Exception

sendUnproposal

protected void sendUnproposal(org.apache.activemq.artemis.api.core.SimpleString groupid,
                              org.apache.activemq.artemis.api.core.SimpleString clusterName,
                              int distance)