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

Class RemoteGroupingHandler

java.lang.Object

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

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

All Implemented Interfaces:

ActiveMQComponent, GroupingHandler, NotificationListener

public final class RemoteGroupingHandler
extends GroupHandlingAbstract

A remote Grouping handler.

This will use management notifications to communicate with the node that has the Local Grouping handler to make proposals.

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.group.impl.GroupHandlingAbstract

address, executor, managementService

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class org.apache.activemq.artemis.core.server.group.impl.GroupHandlingAbstract

addListener, fireUnproposed, forceRemove, sendUnproposal

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteGroupingHandler

public RemoteGroupingHandler(ExecutorFactory executorFactory,
                             ManagementService managementService,
                             SimpleString name,
                             SimpleString address,
                             long timeout,
                             long groupTimeout)

RemoteGroupingHandler

public RemoteGroupingHandler(ManagementService managementService,
                             SimpleString name,
                             SimpleString address,
                             long timeout,
                             long groupTimeout)

Method Detail

getName

public SimpleString getName()

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

isStarted

public boolean isStarted()

resendPending

public void resendPending()
                   throws Exception

Throws:

Exception

propose

public Response propose(Proposal proposal)
                 throws Exception

Throws:

Exception

awaitBindings

public void awaitBindings()

getProposal

public Response getProposal(SimpleString fullID,
                            boolean touchTime)

remove

public void remove(SimpleString groupid,
                   SimpleString clusterName)
            throws Exception

Throws:

Exception

remove

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

Throws:

Exception

proposed

public void proposed(Response response)
              throws Exception

Throws:

Exception

receive

public Response receive(Proposal proposal,
                        int distance)
                 throws Exception

Throws:

Exception

sendProposalResponse

public void sendProposalResponse(Response response,
                                 int distance)
                          throws Exception

Throws:

Exception

addGroupBinding

public void addGroupBinding(GroupBinding groupBinding)

onNotification

public void onNotification(Notification notification)