edu.vub.at.actors.net.cmd
Class CMDInitRequireServices

java.lang.Object
  extended byedu.vub.at.actors.net.cmd.VMCommand
      extended byedu.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.
 
Fields inherited from class edu.vub.at.actors.net.cmd.VMCommand
_TRANSMISSION_TIMEOUT_
 
Constructor Summary
CMDInitRequireServices(java.util.Set 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 edu.vub.at.actors.net.cmd.VMCommand
sendAsyncMulticast, sendAsyncUnicast, sendSynchronousUnicast, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

topics_

private final java.util.Set topics_
A Set of Packet objects representing serialized ATStripe topics.

Constructor Detail

CMDInitRequireServices

public CMDInitRequireServices(java.util.Set topics)
Method Detail

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 executed
wrapper - the JGroups message wrapper that was used to transport this command object
Throws:
java.lang.Exception