org.jdiameter.server.impl.app.ro
Class ServerRoSessionImpl

java.lang.Object
  org.jdiameter.common.impl.app.AppSessionImpl
      org.jdiameter.common.impl.app.ro.AppRoSessionImpl
          org.jdiameter.server.impl.app.ro.ServerRoSessionImpl

All Implemented Interfaces:

java.io.Serializable, AppSession, StateMachine, BaseSession, EventListener<Request,Answer>, NetworkReqListener, ServerRoSession

public class ServerRoSessionImpl
extends AppRoSessionImpl
implements ServerRoSession, NetworkReqListener, EventListener<Request,Answer>

Credit Control Application Server session implementation

Author:

Alexandre Mendonca , Bartosz Baranowski

See Also:

Serialized Form

Field Summary

protected long[]	authAppIds
protected IServerRoSessionContext	context
protected IRoMessageFactory	factory
protected ServerRoSessionListener	listener
protected java.lang.String	originHost
protected java.lang.String	originRealm
protected java.util.concurrent.locks.Lock	sendAndStateLock
protected ServerRoSessionState	state
protected boolean	stateless
protected static java.lang.String	TCC_TIMER_NAME
protected java.io.Serializable	tccTimerId

Fields inherited from class org.jdiameter.common.impl.app.ro.AppRoSessionImpl

stateListeners

Fields inherited from class org.jdiameter.common.impl.app.AppSessionImpl

appId, scheduler, session, sessionDataSource, sessionId, sf, timerFacility

Constructor Summary

ServerRoSessionImpl(IRoMessageFactory fct, SessionFactory sf, ServerRoSessionListener lst, IServerRoSessionContext ctx, StateChangeListener<AppSession> stLst)

ServerRoSessionImpl(java.lang.String sessionId, IRoMessageFactory fct, SessionFactory sf, ServerRoSessionListener lst, IServerRoSessionContext ctx, StateChangeListener<AppSession> stLst)

Method Summary

protected void	dispatchEvent(AppEvent event)
boolean	equals(java.lang.Object obj)
<E> E	getState(java.lang.Class<E> stateType)
boolean	handleEvent(StateEvent event)
int	hashCode()
protected boolean	isProvisional(long resultCode)
boolean	isReplicable()
boolean	isStateless()
protected boolean	isSuccess(long resultCode)
void	onTimer(java.lang.String timerName)
Answer	processRequest(Request request)
void	receivedSuccessMessage(Request request, Answer answer)
void	release()
void	relink(IContainer stack)
protected void	send(Event.Type type, AppRequestEvent request, AppAnswerEvent answer)
void	sendCreditControlAnswer(RoCreditControlAnswer answer)
void	sendReAuthRequest(ReAuthRequest request)
protected void	setState(ServerRoSessionState newState)
protected void	setState(ServerRoSessionState newState, boolean release)
void	timeoutExpired(Request request)
java.lang.String	toString()

Methods inherited from class org.jdiameter.common.impl.app.ro.AppRoSessionImpl

addStateChangeNotification, removeStateChangeNotification

Methods inherited from class org.jdiameter.common.impl.app.AppSessionImpl

getCreationTime, getLastAccessedTime, getSessionAppId, getSessionId, getSessions, isAppSession, isValid

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jdiameter.api.app.AppSession

getSessionAppId, getSessions

Methods inherited from interface org.jdiameter.api.BaseSession

getCreationTime, getLastAccessedTime, getSessionId, isAppSession, isValid

Methods inherited from interface org.jdiameter.api.app.StateMachine

addStateChangeNotification, removeStateChangeNotification

Field Detail

stateless

protected boolean stateless

state

protected ServerRoSessionState state

sendAndStateLock

protected java.util.concurrent.locks.Lock sendAndStateLock

factory

protected transient IRoMessageFactory factory

context

protected transient IServerRoSessionContext context

listener

protected transient ServerRoSessionListener listener

tccTimerId

protected java.io.Serializable tccTimerId

TCC_TIMER_NAME

protected static final java.lang.String TCC_TIMER_NAME

See Also:

Constant Field Values

authAppIds

protected long[] authAppIds

originHost

protected java.lang.String originHost

originRealm

protected java.lang.String originRealm

Constructor Detail

ServerRoSessionImpl

public ServerRoSessionImpl(IRoMessageFactory fct,
                           SessionFactory sf,
                           ServerRoSessionListener lst,
                           IServerRoSessionContext ctx,
                           StateChangeListener<AppSession> stLst)

ServerRoSessionImpl

public ServerRoSessionImpl(java.lang.String sessionId,
                           IRoMessageFactory fct,
                           SessionFactory sf,
                           ServerRoSessionListener lst,
                           IServerRoSessionContext ctx,
                           StateChangeListener<AppSession> stLst)

Method Detail

sendCreditControlAnswer

public void sendCreditControlAnswer(RoCreditControlAnswer answer)
                             throws InternalException,
                                    IllegalDiameterStateException,
                                    RouteException,
                                    OverloadException

Specified by:

sendCreditControlAnswer in interface ServerRoSession

Throws:

InternalException

IllegalDiameterStateException

RouteException

OverloadException

sendReAuthRequest

public void sendReAuthRequest(ReAuthRequest request)
                       throws InternalException,
                              IllegalDiameterStateException,
                              RouteException,
                              OverloadException

Specified by:

sendReAuthRequest in interface ServerRoSession

Throws:

InternalException

IllegalDiameterStateException

RouteException

OverloadException

isStateless

public boolean isStateless()

Specified by:

isStateless in interface AppSession

getState

public <E> E getState(java.lang.Class<E> stateType)

Specified by:

getState in interface StateMachine

handleEvent

public boolean handleEvent(StateEvent event)
                    throws InternalException,
                           OverloadException

Specified by:

handleEvent in interface StateMachine

Throws:

InternalException

OverloadException

isReplicable

public boolean isReplicable()

Specified by:

isReplicable in interface BaseSession

Overrides:

isReplicable in class AppSessionImpl

relink

public void relink(IContainer stack)

Overrides:

relink in class AppRoSessionImpl

processRequest

public Answer processRequest(Request request)

Specified by:

processRequest in interface NetworkReqListener

receivedSuccessMessage

public void receivedSuccessMessage(Request request,
                                   Answer answer)

Specified by:

receivedSuccessMessage in interface EventListener<Request,Answer>

timeoutExpired

public void timeoutExpired(Request request)

Specified by:

timeoutExpired in interface EventListener<Request,Answer>

onTimer

public void onTimer(java.lang.String timerName)

Overrides:

onTimer in class AppSessionImpl

isProvisional

protected boolean isProvisional(long resultCode)

isSuccess

protected boolean isSuccess(long resultCode)

setState

protected void setState(ServerRoSessionState newState)

setState

protected void setState(ServerRoSessionState newState,
                        boolean release)

release

public void release()

Specified by:

release in interface BaseSession

Overrides:

release in class AppRoSessionImpl

send

protected void send(Event.Type type,
                    AppRequestEvent request,
                    AppAnswerEvent answer)
             throws InternalException

Throws:

InternalException

dispatchEvent

protected void dispatchEvent(AppEvent event)
                      throws InternalException

Throws:

InternalException

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object