org.codehaus.wadi.location.partitionmanager.local
Class LocalPartitionMoveIMToPMAction

java.lang.Object
  extended by org.codehaus.wadi.location.partitionmanager.local.AbstractLocalPartitionAction
      extended by org.codehaus.wadi.location.partitionmanager.local.LocalPartitionMoveIMToPMAction

public class LocalPartitionMoveIMToPMAction
extends AbstractLocalPartitionAction

Version:
$Revision: 1538 $

Field Summary
 
Fields inherited from class org.codehaus.wadi.location.partitionmanager.local.AbstractLocalPartitionAction
dispatcher, log, nameToLocation
 
Constructor Summary
LocalPartitionMoveIMToPMAction(org.codehaus.wadi.group.Dispatcher dispatcher, java.util.Map<java.lang.Object,Location> nameToLocation, org.apache.commons.logging.Log log)
           
 
Method Summary
protected  void doRelocateSession(org.codehaus.wadi.group.Envelope message, Location location, MoveIMToPM request, java.lang.String imCorrelationId)
           
 void onMessage(org.codehaus.wadi.group.Envelope message, MoveIMToPM request)
           
protected  void relocateInvocation(Location location, MoveIMToPM request, org.codehaus.wadi.group.Peer pmPeer, java.lang.String imCorrelationId)
           
protected  void relocateSession(org.codehaus.wadi.group.Envelope message, Location location, MoveIMToPM request, java.lang.String imCorrelationId)
           
protected  void replyWithUnknownLocation(org.codehaus.wadi.group.Envelope message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LocalPartitionMoveIMToPMAction

public LocalPartitionMoveIMToPMAction(org.codehaus.wadi.group.Dispatcher dispatcher,
                                      java.util.Map<java.lang.Object,Location> nameToLocation,
                                      org.apache.commons.logging.Log log)
Method Detail

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      MoveIMToPM request)

relocateSession

protected void relocateSession(org.codehaus.wadi.group.Envelope message,
                               Location location,
                               MoveIMToPM request,
                               java.lang.String imCorrelationId)
                        throws org.codehaus.wadi.group.MessageExchangeException
Throws:
org.codehaus.wadi.group.MessageExchangeException

doRelocateSession

protected void doRelocateSession(org.codehaus.wadi.group.Envelope message,
                                 Location location,
                                 MoveIMToPM request,
                                 java.lang.String imCorrelationId)
                          throws org.codehaus.wadi.group.MessageExchangeException
Throws:
org.codehaus.wadi.group.MessageExchangeException

relocateInvocation

protected void relocateInvocation(Location location,
                                  MoveIMToPM request,
                                  org.codehaus.wadi.group.Peer pmPeer,
                                  java.lang.String imCorrelationId)
                           throws org.codehaus.wadi.group.MessageExchangeException
Throws:
org.codehaus.wadi.group.MessageExchangeException

replyWithUnknownLocation

protected void replyWithUnknownLocation(org.codehaus.wadi.group.Envelope message)
                                 throws org.codehaus.wadi.group.MessageExchangeException
Throws:
org.codehaus.wadi.group.MessageExchangeException


Copyright © 2008. All Rights Reserved.