org.codehaus.wadi.location.partitionmanager.remote
Class RemotePartition

java.lang.Object
  extended by org.codehaus.wadi.location.partitionmanager.AbstractPartition
      extended by org.codehaus.wadi.location.partitionmanager.remote.RemotePartition
All Implemented Interfaces:
Partition

public class RemotePartition
extends AbstractPartition

Version:
$Revision:1815 $
Author:
Jules Gosnell

Field Summary
 
Fields inherited from class org.codehaus.wadi.location.partitionmanager.AbstractPartition
_key
 
Constructor Summary
RemotePartition(int key, org.codehaus.wadi.group.Dispatcher dispatcher, org.codehaus.wadi.group.Peer peer)
           
 
Method Summary
 org.codehaus.wadi.group.Envelope exchange(SessionRequestMessage request, long timeout)
          Send a message/request to the Partition and wait for a message/response...
 boolean isLocal()
           
 void onMessage(org.codehaus.wadi.group.Envelope message, DeleteIMToPM request)
          A Peer has destroyed a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, EvacuateIMToPM request)
          A Peer wishes to evacuate a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, InsertIMToPM request)
          A Peer has created a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, MoveIMToPM request)
          A Peer has an Invocation for a Session of which it is not the owner...
 java.lang.String toString()
           
 
Methods inherited from class org.codehaus.wadi.location.partitionmanager.AbstractPartition
getKey
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

RemotePartition

public RemotePartition(int key,
                       org.codehaus.wadi.group.Dispatcher dispatcher,
                       org.codehaus.wadi.group.Peer peer)
Method Detail

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

isLocal

public boolean isLocal()
Returns:
whether or not this is a LocalPartition

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      InsertIMToPM request)
Description copied from interface: Partition
A Peer has created a Session...


onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      DeleteIMToPM request)
Description copied from interface: Partition
A Peer has destroyed a Session...


onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      EvacuateIMToPM request)
Description copied from interface: Partition
A Peer wishes to evacuate a Session...


onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      MoveIMToPM request)
Description copied from interface: Partition
A Peer has an Invocation for a Session of which it is not the owner...


exchange

public org.codehaus.wadi.group.Envelope exchange(SessionRequestMessage request,
                                                 long timeout)
                                          throws org.codehaus.wadi.group.MessageExchangeException
Description copied from interface: Partition
Send a message/request to the Partition and wait for a message/response...

Parameters:
request - The request
timeout - The number of milliseconds to wait for a response
Returns:
the response
Throws:
org.codehaus.wadi.group.MessageExchangeException


Copyright © 2010. All Rights Reserved.