org.hornetq.core.server.group.impl

Class RemoteGroupingHandler

java.lang.Object

org.hornetq.core.server.group.impl.RemoteGroupingHandler

All Implemented Interfaces:

GroupingHandler, NotificationListener

public class RemoteGroupingHandler
extends Object
implements GroupingHandler

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

Author:

Andy Taylor

Constructor Summary

Constructors

Constructor and Description
RemoteGroupingHandler(ManagementService managementService, SimpleString name, SimpleString address, int timeout)

Method Summary

Methods

Modifier and Type	Method and Description
void	addGroupBinding(GroupBinding groupBinding)
SimpleString	getName()
Response	getProposal(SimpleString fullID)
void	onNotification(Notification notification)
Response	propose(Proposal proposal)
void	proposed(Response response)
Response	receive(Proposal proposal, int distance)
void	send(Response response, int distance)

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteGroupingHandler

public RemoteGroupingHandler(ManagementService managementService,
                     SimpleString name,
                     SimpleString address,
                     int timeout)

Method Detail

getName

public SimpleString getName()

Specified by:

getName in interface GroupingHandler

propose

public Response propose(Proposal proposal)
                 throws Exception

Specified by:

propose in interface GroupingHandler

Throws:

Exception

getProposal

public Response getProposal(SimpleString fullID)

Specified by:

getProposal in interface GroupingHandler

proposed

public void proposed(Response response)
              throws Exception

Specified by:

proposed in interface GroupingHandler

Throws:

Exception

receive

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

Specified by:

receive in interface GroupingHandler

Throws:

Exception

send

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

Specified by:

send in interface GroupingHandler

Throws:

Exception

addGroupBinding

public void addGroupBinding(GroupBinding groupBinding)

Specified by:

addGroupBinding in interface GroupingHandler

onNotification

public void onNotification(Notification notification)

Specified by:

onNotification in interface NotificationListener