org.codehaus.wadi.impl
Class ClusteredManager

java.lang.Object
  extended byorg.codehaus.wadi.impl.StandardManager
      extended byorg.codehaus.wadi.impl.DistributableManager
          extended byorg.codehaus.wadi.impl.ClusteredManager
All Implemented Interfaces:
ClusteredContextualiserConfig, Config, ContextualiserConfig, DispatcherConfig, DistributableContextualiserConfig, DistributableSessionConfig, Lifecycle, PartitionManagerConfig, ReplicableSessionConfig, RouterConfig, SessionConfig, StreamerConfig

public class ClusteredManager
extends DistributableManager
implements ClusteredContextualiserConfig, DispatcherConfig, PartitionManagerConfig


Field Summary
protected  Collapser _collapser
           
protected  DIndex _dindex
           
protected  Dispatcher _dispatcher
           
protected  Map _distributedState
           
protected  ProxiedLocation _location
           
protected  PartitionManager _partitionManager
           
protected  InvocationProxy _proxy
           
 
Fields inherited from class org.codehaus.wadi.impl.DistributableManager
_accessOnLoad, _classLoader, _helpers, _replicaterFactory, _shuttingDown, _streamer
 
Fields inherited from class org.codehaus.wadi.impl.StandardManager
_acceptingSessions, _attributeListeners, _attributesFactory, _config, _contextualiser, _errorCounter, _errorIfSessionNotAcquired, _filter, _log, _map, _maxInactiveInterval, _router, _sessionIdFactory, _sessionListeners, _sessionPool, _sessionWrapperFactory, _started, _timer, _valuePool
 
Constructor Summary
ClusteredManager(SessionPool sessionPool, AttributesFactory attributesFactory, ValuePool valuePool, SessionWrapperFactory sessionWrapperFactory, SessionIdFactory sessionIdFactory, Contextualiser contextualiser, Map sessionMap, Router router, boolean errorIfSessionNotAcquired, Streamer streamer, boolean accessOnLoad, ReplicaterFactory replicaterFactory, ProxiedLocation location, InvocationProxy proxy, Dispatcher dispatcher, PartitionManager partitionManager, Collapser collapser)
           
 
Method Summary
 void aboutToStop()
           
 boolean contextualise(InvocationContext invocationContext, String id, Immoter immoter, Sync motionLock, boolean exclusiveOnly)
           
 void destroy(Session session)
           
 void destroy(String key)
           
 void distributeState()
           
 void findRelevantSessionNames(int numPartitions, Collection[] resultSet)
           
 String getContextPath()
           
 Node getCoordinatorNode()
           
 DIndex getDIndex()
           
 Dispatcher getDispatcher()
           
 Map getDistributedState()
           
 Object getDistributedState(Object key)
           
 Immoter getImmoter(String name, Motable immotable)
           
 long getInactiveTime()
           
 Sync getInvocationLock(String name)
           
 InvocationProxy getInvocationProxy()
           
 String getNodeName()
           
 String getNodeName(Destination destination)
           
 int getNumPartitions()
           
 ProxiedLocation getProxiedLocation()
           
 void init(ManagerConfig config)
           
 void notifySessionDeletion(String name)
           
 void notifySessionInsertion(String name)
           
 void notifySessionRelocation(String name)
           
 Object putDistributedState(Object key, Object newValue)
           
 Object removeDistributedState(Object key)
           
 void start()
           
 void stop()
           
protected  boolean validateSessionName(String name)
           
 
Methods inherited from class org.codehaus.wadi.impl.DistributableManager
deregisterHelper, findHelper, getAccessOnLoad, getClassLoader, getDistributable, getHttpSessionAttributeListenersRegistered, getReplicater, getShuttingDown, getStreamer, registerHelper
 
Methods inherited from class org.codehaus.wadi.impl.StandardManager
create, destroy, expire, getAcceptingSessions, getAttributeListeners, getAttributesFactory, getContextualiser, getErrorCount, getErrorIfSessionNotAcquired, getEvictionImmoter, getHttpPort, getManager, getMaxInactiveInterval, getRouter, getServletContext, getSessionCookieDomain, getSessionCookieName, getSessionCookiePath, getSessionIdFactory, getSessionListeners, getSessionPool, getSessionUrlParamName, getSessionWrapperFactory, getTimer, getValuePool, incrementErrorCounter, isStarted, notifySessionCreation, notifySessionDestruction, setAttributelisteners, setFilter, setLastAccessedTime, setMaxInactiveInterval, setMaxInactiveInterval, setSessionListeners
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.codehaus.wadi.DistributableContextualiserConfig
getAccessOnLoad, getContextualiser, getShuttingDown
 
Methods inherited from interface org.codehaus.wadi.ContextualiserConfig
expire, getEvictionImmoter, getMaxInactiveInterval, getRouter, getSessionPool, getTimer
 
Methods inherited from interface org.codehaus.wadi.SessionConfig
getAttributeListeners, getAttributesFactory, getMaxInactiveInterval, getRouter, getServletContext, getSessionIdFactory, getSessionListeners, getSessionWrapperFactory, getValuePool, setLastAccessedTime, setMaxInactiveInterval
 

Field Detail

_dispatcher

protected final Dispatcher _dispatcher

_partitionManager

protected final PartitionManager _partitionManager

_distributedState

protected final Map _distributedState

_collapser

protected final Collapser _collapser

_dindex

protected DIndex _dindex

_proxy

protected final InvocationProxy _proxy

_location

protected final ProxiedLocation _location
Constructor Detail

ClusteredManager

public ClusteredManager(SessionPool sessionPool,
                        AttributesFactory attributesFactory,
                        ValuePool valuePool,
                        SessionWrapperFactory sessionWrapperFactory,
                        SessionIdFactory sessionIdFactory,
                        Contextualiser contextualiser,
                        Map sessionMap,
                        Router router,
                        boolean errorIfSessionNotAcquired,
                        Streamer streamer,
                        boolean accessOnLoad,
                        ReplicaterFactory replicaterFactory,
                        ProxiedLocation location,
                        InvocationProxy proxy,
                        Dispatcher dispatcher,
                        PartitionManager partitionManager,
                        Collapser collapser)
Method Detail

getContextPath

public String getContextPath()
Specified by:
getContextPath in interface DispatcherConfig

init

public void init(ManagerConfig config)
Overrides:
init in class DistributableManager

start

public void start()
           throws Exception
Specified by:
start in interface Lifecycle
Overrides:
start in class StandardManager
Throws:
Exception

aboutToStop

public void aboutToStop()
                 throws Exception
Overrides:
aboutToStop in class StandardManager
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Lifecycle
Overrides:
stop in class StandardManager
Throws:
Exception

destroy

public void destroy(String key)

destroy

public void destroy(Session session)
Specified by:
destroy in interface SessionConfig
Overrides:
destroy in class StandardManager

getNodeName

public String getNodeName()
Specified by:
getNodeName in interface ClusteredContextualiserConfig

getDistributedState

public Object getDistributedState(Object key)
Specified by:
getDistributedState in interface ClusteredContextualiserConfig

putDistributedState

public Object putDistributedState(Object key,
                                  Object newValue)
Specified by:
putDistributedState in interface ClusteredContextualiserConfig

removeDistributedState

public Object removeDistributedState(Object key)
Specified by:
removeDistributedState in interface ClusteredContextualiserConfig

distributeState

public void distributeState()
                     throws Exception
Specified by:
distributeState in interface ClusteredContextualiserConfig
Throws:
Exception

getDistributedState

public Map getDistributedState()
Specified by:
getDistributedState in interface ClusteredContextualiserConfig

getInactiveTime

public long getInactiveTime()
Specified by:
getInactiveTime in interface ClusteredContextualiserConfig

getNumPartitions

public int getNumPartitions()
Specified by:
getNumPartitions in interface ClusteredContextualiserConfig

getDispatcher

public Dispatcher getDispatcher()
Specified by:
getDispatcher in interface ClusteredContextualiserConfig

getDIndex

public DIndex getDIndex()
Specified by:
getDIndex in interface ClusteredContextualiserConfig

notifySessionInsertion

public void notifySessionInsertion(String name)
Specified by:
notifySessionInsertion in interface ContextualiserConfig
Overrides:
notifySessionInsertion in class StandardManager

notifySessionDeletion

public void notifySessionDeletion(String name)
Specified by:
notifySessionDeletion in interface ContextualiserConfig
Overrides:
notifySessionDeletion in class StandardManager

notifySessionRelocation

public void notifySessionRelocation(String name)
Specified by:
notifySessionRelocation in interface ContextualiserConfig
Overrides:
notifySessionRelocation in class StandardManager

validateSessionName

protected boolean validateSessionName(String name)
Overrides:
validateSessionName in class StandardManager

findRelevantSessionNames

public void findRelevantSessionNames(int numPartitions,
                                     Collection[] resultSet)
Specified by:
findRelevantSessionNames in interface PartitionManagerConfig

getInvocationProxy

public InvocationProxy getInvocationProxy()
Specified by:
getInvocationProxy in interface ClusteredContextualiserConfig

getProxiedLocation

public ProxiedLocation getProxiedLocation()
Specified by:
getProxiedLocation in interface ClusteredContextualiserConfig

getCoordinatorNode

public Node getCoordinatorNode()
Specified by:
getCoordinatorNode in interface PartitionManagerConfig

contextualise

public boolean contextualise(InvocationContext invocationContext,
                             String id,
                             Immoter immoter,
                             Sync motionLock,
                             boolean exclusiveOnly)
                      throws InvocationException
Specified by:
contextualise in interface PartitionManagerConfig
Throws:
InvocationException

getImmoter

public Immoter getImmoter(String name,
                          Motable immotable)
Specified by:
getImmoter in interface PartitionManagerConfig

getNodeName

public String getNodeName(Destination destination)
Specified by:
getNodeName in interface PartitionManagerConfig

getInvocationLock

public Sync getInvocationLock(String name)
Specified by:
getInvocationLock in interface PartitionManagerConfig


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