edu.vub.at.actors.net.cmd
Class CMDInitRequireServices
java.lang.Object
edu.vub.at.actors.net.cmd.VMCommand
edu.vub.at.actors.net.cmd.CMDInitRequireServices
- All Implemented Interfaces:
- java.io.Serializable
- public class CMDInitRequireServices
- extends VMCommand
A CMDInitRequireServices message is sent asynchronously to any VM just discovered in the environment
if thhe discovering VM has some open subscriptions. This command is sent to the discovered VM to ask
it whether it has any publications matching the outstanding subscriptions at the sender VM.
SENDER: the discovering VM
RECEIVER: the discovered VM
MODE: ASYNCHRONOUS, UNICAST
PROPERTIES: outstanding subscription topics of sender
REPLY: potential CMDJoinServices
- Author:
- tvcutsem
- See Also:
- Serialized Form
Field Summary |
private java.util.Set |
topics_
A Set of Packet objects representing serialized ATStripe topics. |
Method Summary |
void |
send(org.jgroups.blocks.MessageDispatcher dispatcher,
org.jgroups.Address recipientVM)
|
java.lang.Object |
uponReceiptBy(ELVirtualMachine remoteHost,
org.jgroups.Message wrapper)
To be overridden by subclasses to specify the behaviour to execute upon reception
and execution of the command object at the recipient VM.
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
topics_
private final java.util.Set topics_
- A Set of Packet objects representing serialized ATStripe topics.
CMDInitRequireServices
public CMDInitRequireServices(java.util.Set topics)
send
public void send(org.jgroups.blocks.MessageDispatcher dispatcher,
org.jgroups.Address recipientVM)
uponReceiptBy
public java.lang.Object uponReceiptBy(ELVirtualMachine remoteHost,
org.jgroups.Message wrapper)
throws java.lang.Exception
- Description copied from class:
VMCommand
- To be overridden by subclasses to specify the behaviour to execute upon reception
and execution of the command object at the recipient VM.
This code is still executed in a JGroups thread!
- Specified by:
uponReceiptBy
in class VMCommand
- Parameters:
remoteHost
- the host at which the command arrived and is executedwrapper
- the JGroups message wrapper that was used to transport this command object
- Throws:
java.lang.Exception