org.codehaus.wadi.dindex.impl
Class RemotePartition

java.lang.Object
  extended byorg.codehaus.wadi.dindex.impl.AbstractPartition
      extended byorg.codehaus.wadi.dindex.impl.RemotePartition
All Implemented Interfaces:
Partition, PMPartition, Serializable, SMPartition

public class RemotePartition
extends AbstractPartition

See Also:
Serialized Form

Field Summary
protected  PartitionConfig _config
           
protected  Destination _location
           
protected  Log _log
           
 
Fields inherited from class org.codehaus.wadi.dindex.impl.AbstractPartition
_key
 
Constructor Summary
RemotePartition(int key, PartitionConfig config, Destination location)
           
 
Method Summary
 ObjectMessage exchange(DIndexRequest request, long timeout)
           
 Destination getDestination()
           
 boolean isLocal()
           
 void onMessage(ObjectMessage message, DeleteIMToPM request)
           
 void onMessage(ObjectMessage message, DIndexForwardRequest request)
           
 void onMessage(ObjectMessage message, DIndexRelocationRequest request)
           
 void onMessage(ObjectMessage message, InsertIMToPM request)
           
 void onMessage(ObjectMessage message, MoveIMToPM request)
           
 void setLocation(Destination location)
           
 String toString()
           
 
Methods inherited from class org.codehaus.wadi.dindex.impl.AbstractPartition
getKey
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

_log

protected transient Log _log

_config

protected final PartitionConfig _config

_location

protected Destination _location
Constructor Detail

RemotePartition

public RemotePartition(int key,
                       PartitionConfig config,
                       Destination location)
Method Detail

isLocal

public boolean isLocal()

getDestination

public Destination getDestination()

setLocation

public void setLocation(Destination location)

toString

public String toString()

onMessage

public void onMessage(ObjectMessage message,
                      InsertIMToPM request)

onMessage

public void onMessage(ObjectMessage message,
                      DeleteIMToPM request)

onMessage

public void onMessage(ObjectMessage message,
                      DIndexRelocationRequest request)

onMessage

public void onMessage(ObjectMessage message,
                      DIndexForwardRequest request)

onMessage

public void onMessage(ObjectMessage message,
                      MoveIMToPM request)

exchange

public ObjectMessage exchange(DIndexRequest request,
                              long timeout)
                       throws Exception
Throws:
Exception


Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.