repicea.net.server

Class AbstractServer

java.lang.Object

repicea.app.AbstractGenericEngine

repicea.net.server.AbstractServer

All Implemented Interfaces:

java.beans.PropertyChangeListener, java.util.EventListener

Direct Known Subclasses:

JavaLocalGatewayServer

public abstract class AbstractServer
extends AbstractGenericEngine
implements java.beans.PropertyChangeListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractServer.ServerReply

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.LinkedBlockingQueue<SocketWrapper>	clientQueue
protected boolean	isCallerAJavaApplication

Fields inherited from class repicea.app.AbstractGenericEngine

finalTask, logger, queue, tasksDone

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractServer(ServerConfiguration configuration, boolean isCallerAJavaApplication) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addPropertyChangeListener(java.beans.PropertyChangeListener listener)
protected void	closeAndRestartTheseThreads(java.util.Collection<ClientThread> connectionsToBeClosed)
protected abstract ClientThread	createClientThread(AbstractServer server, int id)
protected void	firePropertyChange(java.lang.String propertyName, java.lang.Object oldValue, java.lang.Object newValue)
protected void	firstTasksToDo() This method sets the first tasks to execute when the engine starts.
protected java.util.List<ClientThread>	getClientThreads() This method returns the vector of client threads.
protected ServerConfiguration	getConfiguration()
protected SocketWrapper	getWaitingClients() This method waits until the head of the queue is non null and returns the socket.
protected void	listenToClients() This method starts the worker thread, which listens to the clients in the queue.
void	propertyChange(java.beans.PropertyChangeEvent evt)
void	removePropertyChangeListener(java.beans.PropertyChangeListener listener)
void	requestShutdown() This method requests the Engine to shut down.
protected void	startReceiverThread() This method starts the callReceiver thread that handles the call from the clients.

Methods inherited from class repicea.app.AbstractGenericEngine

addTask, addTasks, cancelRunningTask, decideWhatToDoInCaseOfFailure, getSettingMemory, lockEngine, lockEngine, setSettingMemory, shutdown, startApplication, unlockEngine

Methods inherited from class java.lang.Object

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

Field Detail

clientQueue

protected final java.util.concurrent.LinkedBlockingQueue<SocketWrapper> clientQueue

isCallerAJavaApplication

protected final boolean isCallerAJavaApplication

Constructor Detail

AbstractServer

protected AbstractServer(ServerConfiguration configuration,
                         boolean isCallerAJavaApplication)
                  throws java.lang.Exception

Constructor.

Parameters:

configuration - a ServerConfiguration instance that defines the number of threads, the reference path and the filename of the exception rules

isCallerAJavaApplication - true if the client is a Java app

Throws:

java.lang.Exception

Method Detail

createClientThread

protected abstract ClientThread createClientThread(AbstractServer server,
                                                   int id)

getWaitingClients

protected SocketWrapper getWaitingClients()
                                   throws java.lang.InterruptedException

This method waits until the head of the queue is non null and returns the socket.

Returns:

a Socket instance

Throws:

java.lang.InterruptedException

listenToClients

protected void listenToClients()

This method starts the worker thread, which listens to the clients in the queue.

startReceiverThread

protected void startReceiverThread()
                            throws java.util.concurrent.ExecutionException,
                                   java.lang.InterruptedException

This method starts the callReceiver thread that handles the call from the clients.

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

getConfiguration

protected ServerConfiguration getConfiguration()

getClientThreads

protected java.util.List<ClientThread> getClientThreads()

This method returns the vector of client threads.

Returns:

a Vector of ClientThread instances

closeAndRestartTheseThreads

protected void closeAndRestartTheseThreads(java.util.Collection<ClientThread> connectionsToBeClosed)

firstTasksToDo

protected void firstTasksToDo()

Description copied from class: AbstractGenericEngine

This method sets the first tasks to execute when the engine starts. Typically, it would retrieve the settings, show the user interface and so on.

Specified by:

firstTasksToDo in class AbstractGenericEngine

addPropertyChangeListener

public void addPropertyChangeListener(java.beans.PropertyChangeListener listener)

removePropertyChangeListener

public void removePropertyChangeListener(java.beans.PropertyChangeListener listener)

firePropertyChange

protected void firePropertyChange(java.lang.String propertyName,
                                  java.lang.Object oldValue,
                                  java.lang.Object newValue)

propertyChange

public void propertyChange(java.beans.PropertyChangeEvent evt)

Specified by:

propertyChange in interface java.beans.PropertyChangeListener

requestShutdown

public void requestShutdown()

Description copied from class: AbstractGenericEngine

This method requests the Engine to shut down. It first clears the queue of tasks and then it sends the FinalTask static member in the queue in order to ensures the shutting down.

Overrides:

requestShutdown in class AbstractGenericEngine