public final class RemoteGroupingHandler extends Object implements GroupingHandler
This will use management notifications to communicate with the node that has the Local Grouping handler to make proposals.
Constructor and Description |
---|
RemoteGroupingHandler(ManagementService managementService,
SimpleString name,
SimpleString address,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
addGroupBinding(GroupBinding groupBinding) |
void |
awaitBindings() |
SimpleString |
getName() |
Response |
getProposal(SimpleString fullID) |
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,
int distance) |
void |
send(Response response,
int distance) |
void |
start() |
void |
stop() |
public RemoteGroupingHandler(ManagementService managementService, SimpleString name, SimpleString address, long timeout)
public SimpleString getName()
getName
in interface GroupingHandler
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public boolean isStarted()
isStarted
in interface HornetQComponent
public Response propose(Proposal proposal) throws Exception
propose
in interface GroupingHandler
Exception
public Response getProposal(SimpleString fullID)
getProposal
in interface GroupingHandler
public void awaitBindings()
awaitBindings
in interface GroupingHandler
public void remove(SimpleString groupid, SimpleString clusterName, int distance) throws Exception
remove
in interface GroupingHandler
Exception
public void proposed(Response response) throws Exception
proposed
in interface GroupingHandler
Exception
public Response receive(Proposal proposal, int distance) throws Exception
receive
in interface GroupingHandler
Exception
public void send(Response response, int distance) throws Exception
send
in interface GroupingHandler
Exception
public void addGroupBinding(GroupBinding groupBinding)
addGroupBinding
in interface GroupingHandler
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.