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

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

All Implemented Interfaces:

java.io.Serializable

public class CMDJoinServices

extends VMCommand

A CMDJoinServices message is sent asynchronously as a reply to: - an initial discovery request from a VM - a subsequent discovery request when a VM subscribes to a new service SENDER: the VM that provides some service objects RECEIVER: the VM that previously sent a request for required services MODE: ASYNCHRONOUS, UNICAST PROPERTIES: a map of subscription topic to published objects REPLY: none

Author:

tvcutsem

See Also:

Serialized Form

Field Summary

private MultiMap

providedServices_ A map from serialized ATStripe topics to Sets of serialized ATObjects that provide the serialized topic

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

_TRANSMISSION_TIMEOUT_

Constructor Summary

CMDJoinServices(MultiMap providedServices)

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

providedServices_

private final MultiMap providedServices_

A map from serialized ATStripe topics to Sets of serialized ATObjects that provide the serialized topic

Constructor Detail

CMDJoinServices

public CMDJoinServices(MultiMap providedServices)

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