org.mobicents.diameter.impl.ha.data

Class ReplicatedSessionDatasource

java.lang.Object

org.mobicents.diameter.impl.ha.data.ReplicatedSessionDatasource

All Implemented Interfaces:

ISessionDatasource, org.mobicents.cluster.DataRemovalListener

public class ReplicatedSessionDatasource
extends Object
implements ISessionDatasource, org.mobicents.cluster.DataRemovalListener

Replicated datasource implementation for ISessionDatasource

Author:

Alexandre Mendonca , Bartosz Baranowski

Field Summary

Fields

Modifier and Type	Field and Description
protected HashMap<Class<? extends IAppSessionData>,IAppSessionDataFactory<? extends IAppSessionData>>	appSessionDataFactories
static String	CLUSTER_DS_DEFAULT_FILE
static String	SESSIONS
static org.jboss.cache.Fqn	SESSIONS_FQN

Constructor Summary

Constructors

Constructor and Description
ReplicatedSessionDatasource(IContainer container)
ReplicatedSessionDatasource(IContainer container, ISessionDatasource localDataSource, String cacheConfigFilename)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSession(BaseSession session)
void	dataRemoved(org.jboss.cache.Fqn sessionFqn)
boolean	exists(String sessionId)
org.jboss.cache.Fqn	getBaseFqn()
IContainer	getContainer()
IAppSessionDataFactory<? extends IAppSessionData>	getDataFactory(Class<? extends IAppSessionData> x)
org.mobicents.cluster.MobicentsCluster	getMobicentsCluster()
BaseSession	getSession(String sessionId)
NetworkReqListener	getSessionListener(String sessionId)
boolean	isClustered()
void	removeSession(String sessionId)
NetworkReqListener	removeSessionListener(String sessionId)
void	setSessionListener(String sessionId, NetworkReqListener data)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLUSTER_DS_DEFAULT_FILE

public static final String CLUSTER_DS_DEFAULT_FILE

See Also:

Constant Field Values

appSessionDataFactories

protected HashMap<Class<? extends IAppSessionData>,IAppSessionDataFactory<? extends IAppSessionData>> appSessionDataFactories

SESSIONS

public static final String SESSIONS

See Also:

Constant Field Values

SESSIONS_FQN

public static final org.jboss.cache.Fqn SESSIONS_FQN

Constructor Detail

ReplicatedSessionDatasource

public ReplicatedSessionDatasource(IContainer container)

ReplicatedSessionDatasource

public ReplicatedSessionDatasource(IContainer container,
                           ISessionDatasource localDataSource,
                           String cacheConfigFilename)

Method Detail

exists

public boolean exists(String sessionId)

Specified by:

exists in interface ISessionDatasource

addSession

public void addSession(BaseSession session)

Specified by:

addSession in interface ISessionDatasource

getSession

public BaseSession getSession(String sessionId)

Specified by:

getSession in interface ISessionDatasource

getSessionListener

public NetworkReqListener getSessionListener(String sessionId)

Specified by:

getSessionListener in interface ISessionDatasource

removeSession

public void removeSession(String sessionId)

Specified by:

removeSession in interface ISessionDatasource

removeSessionListener

public NetworkReqListener removeSessionListener(String sessionId)

Specified by:

removeSessionListener in interface ISessionDatasource

setSessionListener

public void setSessionListener(String sessionId,
                      NetworkReqListener data)

Specified by:

setSessionListener in interface ISessionDatasource

start

public void start()

Specified by:

start in interface ISessionDatasource

stop

public void stop()

Specified by:

stop in interface ISessionDatasource

isClustered

public boolean isClustered()

Specified by:

isClustered in interface ISessionDatasource

getDataFactory

public IAppSessionDataFactory<? extends IAppSessionData> getDataFactory(Class<? extends IAppSessionData> x)

Specified by:

getDataFactory in interface ISessionDatasource

getMobicentsCluster

public org.mobicents.cluster.MobicentsCluster getMobicentsCluster()

dataRemoved

public void dataRemoved(org.jboss.cache.Fqn sessionFqn)

Specified by:

dataRemoved in interface org.mobicents.cluster.DataRemovalListener

getBaseFqn

public org.jboss.cache.Fqn getBaseFqn()

Specified by:

getBaseFqn in interface org.mobicents.cluster.DataRemovalListener

getContainer

public IContainer getContainer()