org.codehaus.wadi.core.assembler
Class StackContext

java.lang.Object
  extended by org.codehaus.wadi.core.assembler.StackContext

public class StackContext
extends java.lang.Object

Version:
$Revision: 1538 $

Field Summary
protected  ClusteredManager manager
           
protected  ConcurrentMotableMap memoryMap
           
protected  PartitionManager partitionManager
           
protected  PartitionMapper partitionMapper
           
protected  ReplicaStorage replicaStorage
           
protected  ReplicationManager replicationManager
           
protected  Router router
           
protected  ServiceSpace serviceSpace
           
protected  SessionFactory sessionFactory
           
protected  ObjectStateHandler stateHandler
           
protected  StateManager stateManager
           
protected  java.util.Timer timer
           
protected  Dispatcher underlyingDispatcher
           
 
Constructor Summary
StackContext(java.lang.ClassLoader cl, ServiceSpaceName serviceSpaceName, Dispatcher underlyingDispatcher, int sessionTimeout, int numPartitions, int sweepInterval, BackingStrategyFactory backingStrategyFactory)
           
StackContext(ServiceSpaceName serviceSpaceName, Dispatcher underlyingDispatcher)
           
StackContext(ServiceSpaceName serviceSpaceName, Dispatcher underlyingDispatcher, int sessionTimeout)
           
 
Method Summary
 void build()
           
 Manager getManager()
           
 ConcurrentMotableMap getMemoryMap()
           
 PartitionManager getPartitionManager()
           
 PartitionMapper getPartitionMapper()
           
 ReplicationManager getReplicationManager()
           
 ServiceSpace getServiceSpace()
           
 ServiceSpaceName getServiceSpaceName()
           
 SessionMonitor getSessionMonitor()
           
 StateManager getStateManager()
           
 boolean isDisableReplication()
           
protected  Contextualiser newClusteredContextualiser(Contextualiser contextualiser)
           
protected  Contextualiser newCollapserContextualiser(Contextualiser contextualiser, ConcurrentMotableMap mmap)
           
protected  OswegoConcurrentMotableMap newConcurrentMap()
           
protected  Contextualiser newMemoryContextualiser(Contextualiser next, ConcurrentMotableMap mmap)
           
protected  MemoryContextualiser newMemoryContextualiser(Contextualiser next, ConcurrentMotableMap mmap, Evicter mevicter)
           
protected  ObjectStateHandler newObjectStateHandler(Streamer streamer)
           
protected  PartitionBalancerSingletonServiceHolder newPartitionBalancerSingletonServiceHolder()
           
protected  PartitionManager newPartitionManager()
           
protected  PartitionMapper newPartitionMapper()
           
protected  Contextualiser newReplicaAwareContextualiser(Contextualiser next)
           
protected  ReplicaStorageFactory newReplicaStorageFactory()
           
protected  ReplicationManager newReplicationManager()
           
protected  ReplicationManagerFactory newReplicationManagerFactory()
           
protected  Router newRouter()
           
protected  ClassIndexerRegistry newServiceClassIndexerRegistry()
           
protected  SessionFactory newSessionFactory(Streamer streamer)
           
protected  SessionMonitor newSessionMonitor()
           
protected  Contextualiser newSharedStoreContextualiser(Contextualiser next)
           
protected  StateManager newStateManager()
           
protected  SimpleStreamer newStreamer()
           
protected  DistributableValueFactory newValueFactory(ValueHelperRegistry valueHelperRegistry)
           
protected  BasicValueHelperRegistry newValueHelperRegistry()
           
protected  void registerClusteredManager(ClusteredManager manager)
           
protected  void registerMovePMToSMEndPoint(Contextualiser contextualiser)
           
protected  void registerPartitionManager()
           
protected  void registerReleaseEntryRequestEndPoint(Contextualiser contextualiser)
           
protected  void registerReplicaStorage()
           
protected  void registerReplicationManager()
           
protected  void registerRepopulationEndPoint(Contextualiser contextualiser)
           
protected  void registerStackExplorer(ContextualiserStackExplorer stackExplorer)
           
protected  void registerStateManager()
           
 void setDisableReplication(boolean disableReplication)
           
 void setSharedStore(Store sharedStore)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

underlyingDispatcher

protected final Dispatcher underlyingDispatcher

serviceSpace

protected ServiceSpace serviceSpace

partitionMapper

protected PartitionMapper partitionMapper

partitionManager

protected PartitionManager partitionManager

stateManager

protected StateManager stateManager

timer

protected java.util.Timer timer

replicationManager

protected ReplicationManager replicationManager

replicaStorage

protected ReplicaStorage replicaStorage

sessionFactory

protected SessionFactory sessionFactory

manager

protected ClusteredManager manager

memoryMap

protected ConcurrentMotableMap memoryMap

router

protected Router router

stateHandler

protected ObjectStateHandler stateHandler
Constructor Detail

StackContext

public StackContext(ServiceSpaceName serviceSpaceName,
                    Dispatcher underlyingDispatcher)

StackContext

public StackContext(ServiceSpaceName serviceSpaceName,
                    Dispatcher underlyingDispatcher,
                    int sessionTimeout)

StackContext

public StackContext(java.lang.ClassLoader cl,
                    ServiceSpaceName serviceSpaceName,
                    Dispatcher underlyingDispatcher,
                    int sessionTimeout,
                    int numPartitions,
                    int sweepInterval,
                    BackingStrategyFactory backingStrategyFactory)
Method Detail

build

public void build()
           throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

newServiceClassIndexerRegistry

protected ClassIndexerRegistry newServiceClassIndexerRegistry()

newConcurrentMap

protected OswegoConcurrentMotableMap newConcurrentMap()

newObjectStateHandler

protected ObjectStateHandler newObjectStateHandler(Streamer streamer)

newReplicaStorageFactory

protected ReplicaStorageFactory newReplicaStorageFactory()

newReplicationManagerFactory

protected ReplicationManagerFactory newReplicationManagerFactory()

registerStackExplorer

protected void registerStackExplorer(ContextualiserStackExplorer stackExplorer)
                              throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerStateManager

protected void registerStateManager()
                             throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerPartitionManager

protected void registerPartitionManager()
                                 throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

newSessionMonitor

protected SessionMonitor newSessionMonitor()

registerClusteredManager

protected void registerClusteredManager(ClusteredManager manager)
                                 throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerReplicationManager

protected void registerReplicationManager()
                                   throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerReplicaStorage

protected void registerReplicaStorage()
                               throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerReleaseEntryRequestEndPoint

protected void registerReleaseEntryRequestEndPoint(Contextualiser contextualiser)
                                            throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerMovePMToSMEndPoint

protected void registerMovePMToSMEndPoint(Contextualiser contextualiser)
                                   throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

registerRepopulationEndPoint

protected void registerRepopulationEndPoint(Contextualiser contextualiser)
                                     throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

newRouter

protected Router newRouter()

newSessionFactory

protected SessionFactory newSessionFactory(Streamer streamer)

newStreamer

protected SimpleStreamer newStreamer()

newValueFactory

protected DistributableValueFactory newValueFactory(ValueHelperRegistry valueHelperRegistry)

newValueHelperRegistry

protected BasicValueHelperRegistry newValueHelperRegistry()

newStateManager

protected StateManager newStateManager()

newPartitionMapper

protected PartitionMapper newPartitionMapper()

newPartitionManager

protected PartitionManager newPartitionManager()
                                        throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

newPartitionBalancerSingletonServiceHolder

protected PartitionBalancerSingletonServiceHolder newPartitionBalancerSingletonServiceHolder()
                                                                                      throws ServiceAlreadyRegisteredException
Throws:
ServiceAlreadyRegisteredException

newReplicationManager

protected ReplicationManager newReplicationManager()

newCollapserContextualiser

protected Contextualiser newCollapserContextualiser(Contextualiser contextualiser,
                                                    ConcurrentMotableMap mmap)

newMemoryContextualiser

protected Contextualiser newMemoryContextualiser(Contextualiser next,
                                                 ConcurrentMotableMap mmap)

newMemoryContextualiser

protected MemoryContextualiser newMemoryContextualiser(Contextualiser next,
                                                       ConcurrentMotableMap mmap,
                                                       Evicter mevicter)

newClusteredContextualiser

protected Contextualiser newClusteredContextualiser(Contextualiser contextualiser)

newSharedStoreContextualiser

protected Contextualiser newSharedStoreContextualiser(Contextualiser next)

newReplicaAwareContextualiser

protected Contextualiser newReplicaAwareContextualiser(Contextualiser next)

getPartitionManager

public PartitionManager getPartitionManager()

getPartitionMapper

public PartitionMapper getPartitionMapper()

getReplicationManager

public ReplicationManager getReplicationManager()

getServiceSpace

public ServiceSpace getServiceSpace()

getServiceSpaceName

public ServiceSpaceName getServiceSpaceName()

getStateManager

public StateManager getStateManager()

getManager

public Manager getManager()

getMemoryMap

public ConcurrentMotableMap getMemoryMap()

getSessionMonitor

public SessionMonitor getSessionMonitor()

isDisableReplication

public boolean isDisableReplication()

setDisableReplication

public void setDisableReplication(boolean disableReplication)

setSharedStore

public void setSharedStore(Store sharedStore)


Copyright © 2011. All Rights Reserved.