Package org.serviceconnector.server

Class StatefulServer

java.lang.Object

org.serviceconnector.server.Server

org.serviceconnector.server.StatefulServer

All Implemented Interfaces:

IServer, IStatefulServer

public class StatefulServer
extends Server
implements IStatefulServer

The Class StatefulServer.

Field Summary

Fields inherited from class org.serviceconnector.server.Server

destroyed, operationTimeoutMultiplier, remoteNodeConfiguration, requester, serverKey, serverTimeoutMillis, socketAddress

Constructor Summary

Constructors

Constructor	Description
StatefulServer(RemoteNodeConfiguration remoteNodeConfiguration, String serviceName, InetSocketAddress socketAddress)	Instantiates a new stateful server.

Method Summary

Modifier and Type	Method	Description
void	abortSession(AbstractSession session, String reason)	Abort session.
void	abortSessionAndWaitMech(int oti, SCMPMessage abortMessage, String reason, boolean abortSubscription)	Abort session and wait mech.
void	abortSessionsAndDestroy(String reason)	Abort sessions and destroy.
void	addSession(AbstractSession session)	Adds the session.
void	changeSubscription(SCMPMessage message, ISCMPMessageCallback callback, int timeoutMillis)	Change subscription.
void	createSession(SCMPMessage msgToForward, ISCMPMessageCallback callback, int timeoutMillis)	Creates the session.
void	deleteSession(SCMPMessage message, ISCMPMessageCallback callback, int timeoutMillis)	Delete session.
void	destroy()	Destroy.
void	dump(XMLDumpWriter writer)	Dump the server into the xml writer.
void	execute(SCMPMessage message, ISCMPMessageCallback callback, int timeoutMillis)	Send data.
int	getMaxSessions()	Gets the max sessions.
StatefulService	getService()	Gets the service.
String	getServiceName()	Gets the service name.
int	getSessionCount()	Gets the session count.
List<AbstractSession>	getSessions()	Gets the sessions.
boolean	hasFreeSession()	Checks for free session.
void	removeSession(AbstractSession session)	Removes the session.
void	setService(StatefulService service)	Sets the service.
void	subscribe(SCMPMessage msgToForward, ISCMPMessageCallback callback, int timeoutMillis)	Subscribe.
String	toString()	To string.
void	unsubscribe(SCMPMessage message, ISCMPMessageCallback callback, int timeoutMillis)	Unsubscribe.

Methods inherited from class org.serviceconnector.server.Server

getConnectionType, getHost, getMaxConnections, getPortNr, getRequester, getServerKey, getServerTimeoutMillis, getSocketAddress, getTimeout, getTimeouterTask, getType, immediateConnect, isDestroyed, setTimeout, setTimeouterTask

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.serviceconnector.server.IStatefulServer

getType

Constructor Details

StatefulServer

public StatefulServer(RemoteNodeConfiguration remoteNodeConfiguration,
 String serviceName,
 InetSocketAddress socketAddress)

Instantiates a new stateful server.

Parameters:

remoteNodeConfiguration - the remote node configuration

serviceName - the service name

socketAddress - the socket address

Method Details

hasFreeSession

public boolean hasFreeSession()

Checks for free session.

Specified by:

hasFreeSession in interface IStatefulServer

Returns:

true, if successful true, if successful

addSession

public void addSession(AbstractSession session)

Adds the session.

Specified by:

addSession in interface IStatefulServer

Parameters:

session - the session the session

removeSession

public void removeSession(AbstractSession session)

Removes the session.

Specified by:

removeSession in interface IStatefulServer

Parameters:

session - the session the abstract session

getSessions

public List<AbstractSession> getSessions()

Gets the sessions.

Specified by:

getSessions in interface IStatefulServer

Returns:

the sessions the sessions

getSessionCount

public int getSessionCount()

Gets the session count.

Specified by:

getSessionCount in interface IStatefulServer

Returns:

the session count

getMaxSessions

public int getMaxSessions()

Gets the max sessions.

Specified by:

getMaxSessions in interface IStatefulServer

Returns:

the max sessions the max sessions

getServiceName

public String getServiceName()

Gets the service name.

Returns:

the service name

createSession

public void createSession(SCMPMessage msgToForward,
 ISCMPMessageCallback callback,
 int timeoutMillis)
                   throws ConnectionPoolBusyException

Creates the session.

Parameters:

msgToForward - the message to forward

callback - the callback

timeoutMillis - the timeout millis

Throws:

ConnectionPoolBusyException - the connection pool busy exception

deleteSession

public void deleteSession(SCMPMessage message,
 ISCMPMessageCallback callback,
 int timeoutMillis)
                   throws ConnectionPoolBusyException

Delete session.

Parameters:

message - the message

callback - the callback

timeoutMillis - the timeout millis

Throws:

ConnectionPoolBusyException - the connection pool busy exception

subscribe

public void subscribe(SCMPMessage msgToForward,
 ISCMPMessageCallback callback,
 int timeoutMillis)
               throws ConnectionPoolBusyException

Subscribe.

Parameters:

msgToForward - the message to forward

callback - the callback

timeoutMillis - the timeout millis

Throws:

ConnectionPoolBusyException - the connection pool busy exception

unsubscribe

public void unsubscribe(SCMPMessage message,
 ISCMPMessageCallback callback,
 int timeoutMillis)
                 throws ConnectionPoolBusyException

Unsubscribe.

Parameters:

message - the message

callback - the callback

timeoutMillis - the timeout millis

Throws:

ConnectionPoolBusyException - the connection pool busy exception

changeSubscription

public void changeSubscription(SCMPMessage message,
 ISCMPMessageCallback callback,
 int timeoutMillis)
                        throws ConnectionPoolBusyException

Change subscription.

Parameters:

message - the message

callback - the callback

timeoutMillis - the timeout milliseconds

Throws:

ConnectionPoolBusyException - the connection pool busy exception

execute

public void execute(SCMPMessage message,
 ISCMPMessageCallback callback,
 int timeoutMillis)
             throws ConnectionPoolBusyException

Send data. Tries sending data to server asynchronous.

Parameters:

message - the message

callback - the callback

timeoutMillis - the timeout millis

Throws:

ConnectionPoolBusyException - the connection pool busy exception

abortSession

public void abortSession(AbstractSession session,
 String reason)

Abort session.

Specified by:

abortSession in interface IServer

Specified by:

abortSession in interface IStatefulServer

Parameters:

session - the session

reason - the reason the reason

abortSessionAndWaitMech

public void abortSessionAndWaitMech(int oti,
 SCMPMessage abortMessage,
 String reason,
 boolean abortSubscription)

Abort session and wait mech.

Parameters:

oti - the oti

abortMessage - the abort message

reason - the reason

abortSubscription - the abort subscription

abortSessionsAndDestroy

public void abortSessionsAndDestroy(String reason)

Abort sessions and destroy. All sessions are aborted and server gets destroyed.

Parameters:

reason - the reason

getService

public StatefulService getService()

Gets the service.

Returns:

the service

setService

public void setService(StatefulService service)

Sets the service.

Parameters:

service - the new service

destroy

public void destroy()

Destroy. Destroy server.

Overrides:

destroy in class Server

toString

public String toString()

To string.

Overrides:

toString in class Server

Returns:

the string

dump

public void dump(XMLDumpWriter writer)
          throws Exception

Dump the server into the xml writer.

Specified by:

dump in interface IServer

Parameters:

writer - the writer

Throws:

Exception - the exception