org.codehaus.wadi.impl
Class ClusteredManager
java.lang.Object
org.codehaus.wadi.impl.StandardManager
org.codehaus.wadi.impl.DistributableManager
org.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
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)
|
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.SessionConfig |
getAttributeListeners, getAttributesFactory, getMaxInactiveInterval, getRouter, getServletContext, getSessionIdFactory, getSessionListeners, getSessionWrapperFactory, getValuePool, setLastAccessedTime, setMaxInactiveInterval |
_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
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)
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.