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

java.lang.Object
  edu.vub.at.actors.net.cmd.VMCommand
      edu.vub.at.actors.net.cmd.CMDRequireService

All Implemented Interfaces:

java.io.Serializable

public class CMDRequireService

extends VMCommand

A CMDRequireService message is sent asynchronously to all connected VMs when an actor on the sender VM has issued a new subscription. This command is sent to all VMs to ask them whether they have any publications matching the outstanding subscriptions at the sender VM. The reply comes asynchronously in the form of a CMDJoinServices command. SENDER: the VM that issued a new subscription on a topic RECEIVER: all connected VMs MODE: ASYNCHRONOUS, MULTICAST PROPERTIES: the new subscription topic of the sender REPLY: potential CMDJoinServices

Author:

tvcutsem

See Also:

Serialized Form

Field Summary

private Packet

serializedTopic_

Fields inherited from class edu.vub.at.actors.net.cmd.VMCommand

_TRANSMISSION_TIMEOUT_

Constructor Summary

CMDRequireService(Packet topic)

Method Summary

void	send(org.jgroups.blocks.MessageDispatcher dispatcher)
java.lang.Object	uponReceiptBy(ELVirtualMachine remoteHost, org.jgroups.Message wrapper) When a connected VM receives a CMDRequireService request, it queries its local publications to see if there is a match.

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

serializedTopic_

private final Packet serializedTopic_

Constructor Detail

CMDRequireService

public CMDRequireService(Packet topic)

Method Detail

send

public void send(org.jgroups.blocks.MessageDispatcher dispatcher)

uponReceiptBy

public java.lang.Object uponReceiptBy(ELVirtualMachine remoteHost,
                                      org.jgroups.Message wrapper)
                               throws java.lang.Exception

When a connected VM receives a CMDRequireService request, it queries its local publications to see if there is a match. If so, all matching local publications are replied.

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