|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.wadi.location.partitionmanager.local.BasicLocalPartition
public class BasicLocalPartition
Constructor Summary | |
---|---|
protected |
BasicLocalPartition()
|
|
BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher,
int key)
|
|
BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher,
LocalPartition prototype)
|
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... |
int |
getKey()
|
java.util.Map<java.lang.Object,Location> |
getNameToLocation()
|
boolean |
isLocal()
|
void |
merge(LocalPartition content)
|
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... |
void |
put(java.util.Collection<java.lang.Object> names,
org.codehaus.wadi.group.Peer peer)
|
java.lang.String |
toString()
|
void |
waitForClientCompletion()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
protected BasicLocalPartition()
public BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher, int key)
public BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher, LocalPartition prototype)
Method Detail |
---|
public int getKey()
getKey
in interface Partition
public boolean isLocal()
isLocal
in interface Partition
public void onMessage(org.codehaus.wadi.group.Envelope message, InsertIMToPM request)
Partition
onMessage
in interface Partition
public void onMessage(org.codehaus.wadi.group.Envelope message, DeleteIMToPM request)
Partition
onMessage
in interface Partition
public void onMessage(org.codehaus.wadi.group.Envelope message, MoveIMToPM request)
Partition
onMessage
in interface Partition
public void onMessage(org.codehaus.wadi.group.Envelope message, EvacuateIMToPM request)
Partition
onMessage
in interface Partition
public org.codehaus.wadi.group.Envelope exchange(SessionRequestMessage request, long timeout) throws org.codehaus.wadi.group.MessageExchangeException
Partition
exchange
in interface Partition
request
- The requesttimeout
- The number of milliseconds to wait for a response
org.codehaus.wadi.group.MessageExchangeException
public void waitForClientCompletion()
waitForClientCompletion
in interface LocalPartition
public void put(java.util.Collection<java.lang.Object> names, org.codehaus.wadi.group.Peer peer)
put
in interface LocalPartition
public java.util.Map<java.lang.Object,Location> getNameToLocation()
getNameToLocation
in interface LocalPartition
public void merge(LocalPartition content)
merge
in interface LocalPartition
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |