org.codehaus.wadi.dindex.impl
Class LocalPartition
java.lang.Object
org.codehaus.wadi.dindex.impl.AbstractPartition
org.codehaus.wadi.dindex.impl.LocalPartition
- All Implemented Interfaces:
- Partition, PMPartition, Serializable, SMPartition
- public class LocalPartition
- extends AbstractPartition
- implements Serializable
- See Also:
- Serialized Form
_log
protected transient Log _log
_lockLog
protected transient Log _lockLog
_map
protected Map _map
_config
protected transient PartitionConfig _config
LocalPartition
public LocalPartition(int key)
LocalPartition
protected LocalPartition()
init
public void init(PartitionConfig config)
isLocal
public boolean isLocal()
- Specified by:
isLocal
in interface PMPartition
toString
public String toString()
put
public void put(String name,
Destination destination)
onMessage
public void onMessage(ObjectMessage message,
InsertIMToPM request)
- Specified by:
onMessage
in interface Partition
onMessage
public void onMessage(ObjectMessage message,
DeleteIMToPM request)
- Specified by:
onMessage
in interface Partition
onMessage
public void onMessage(ObjectMessage message,
DIndexRelocationRequest request)
- Specified by:
onMessage
in interface Partition
onMessage
public void onMessage(ObjectMessage message,
DIndexForwardRequest request)
- Specified by:
onMessage
in interface Partition
onMessage
public void onMessage(ObjectMessage message1,
MoveIMToPM request)
- Specified by:
onMessage
in interface Partition
exchange
public ObjectMessage exchange(DIndexRequest request,
long timeout)
throws Exception
- Specified by:
exchange
in interface Partition
- Throws:
Exception
Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.