org.apache.catalina.ha.session

Class BackupManager

public class BackupManager extends StandardManager implements ClusterManager, AbstractReplicatedMap.MapOwner

Version: 1.0

Author: Filip Hanik

Field Summary
protected CatalinaCluster	cluster A reference to the cluster
protected static long	DEFAULT_REPL_TIMEOUT
static Log	log
protected boolean	mExpireSessionsOnShutdown Set to true if we don't want the sessions to expire on shutdown
protected String	name The name of this manager

Constructor Summary
	BackupManager() Constructor, just calls super()

Method Summary
ClusterManager	cloneFromTemplate()
Session	createEmptySession()
boolean	doDomainReplication()
int	getActiveSessionsFull()
ClassLoader[]	getClassLoaders()
CatalinaCluster	getCluster()
boolean	getDistributable()
boolean	getExpireSessionsOnShutdown()
String[]	getInvalidatedSessions()
String	getMapName()
int	getMapSendOptions()
String	getName()
ReplicationStream	getReplicationStream(byte[] data) Open Stream and use correct ClassLoader (Container) Switch ThreadClassLoader
ReplicationStream	getReplicationStream(byte[] data, int offset, int length)
boolean	isDefaultMode()
boolean	isNotifyListenersOnReplication()
String	listSessionIdsFull()
void	messageDataReceived(ClusterMessage msg)
void	objectMadePrimay(Object key, Object value)
ClusterMessage	requestCompleted(String sessionId)
void	setCluster(CatalinaCluster cluster)
void	setDefaultMode(boolean defaultMode)
void	setDistributable(boolean dist)
void	setDomainReplication(boolean sendClusterDomainOnly)
void	setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
void	setMapSendOptions(int mapSendOptions)
void	setName(String name)
void	setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
void	start() Prepare for the beginning of active use of the public methods of this component.
void	stop() Gracefully terminate the active use of the public methods of this component.
void	unload() Override persistence since they don't go hand in hand with replication for now.

Field Detail

cluster

protected CatalinaCluster cluster

A reference to the cluster

DEFAULT_REPL_TIMEOUT

protected static long DEFAULT_REPL_TIMEOUT

mExpireSessionsOnShutdown

protected boolean mExpireSessionsOnShutdown

Set to true if we don't want the sessions to expire on shutdown

name

protected String name

The name of this manager

Constructor Detail

BackupManager

public BackupManager()

Constructor, just calls super()

Method Detail

cloneFromTemplate

public ClusterManager cloneFromTemplate()

getExpireSessionsOnShutdown

public boolean getExpireSessionsOnShutdown()

getInvalidatedSessions

public String[] getInvalidatedSessions()

getReplicationStream

public ReplicationStream getReplicationStream(byte[] data)

Open Stream and use correct ClassLoader (Container) Switch ThreadClassLoader

Parameters: data

Returns: The object input stream

Throws: IOException

getReplicationStream

public ReplicationStream getReplicationStream(byte[] data, int offset, int length)

isDefaultMode

public boolean isDefaultMode()

Returns: Returns the defaultMode.

isNotifyListenersOnReplication

public boolean isNotifyListenersOnReplication()

messageDataReceived

public void messageDataReceived(ClusterMessage msg)

objectMadePrimay

public void objectMadePrimay(Object key, Object value)

requestCompleted

public ClusterMessage requestCompleted(String sessionId)

setCluster

public void setCluster(CatalinaCluster cluster)

setDefaultMode

public void setDefaultMode(boolean defaultMode)

Parameters: defaultMode The defaultMode to set.

setDistributable

public void setDistributable(boolean dist)

setDomainReplication

public void setDomainReplication(boolean sendClusterDomainOnly)

Parameters: sendClusterDomainOnly The sendClusterDomainOnly to set.

setExpireSessionsOnShutdown

public void setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)

setMapSendOptions

public void setMapSendOptions(int mapSendOptions)

setNotifyListenersOnReplication

public void setNotifyListenersOnReplication(boolean notifyListenersOnReplication)

Prepare for the beginning of active use of the public methods of this component. This method should be called after configure(), and before any of the public methods of the component are utilized.
Starts the cluster communication channel, this will connect with the other nodes in the cluster, and request the current session state to be transferred to this node.

Throws: IllegalStateException if this component has already been started LifecycleException if this component detects a fatal error that prevents this component from being used

stop

public void stop()

Gracefully terminate the active use of the public methods of this component. This method should be the last one called on a given instance of this component.
This will disconnect the cluster communication channel and stop the listener thread.

Throws: IllegalStateException if this component has not been started LifecycleException if this component detects a fatal error that needs to be reported

unload

public void unload()

Override persistence since they don't go hand in hand with replication for now.