com.lightstreamer.adapters.remote

Class Server

java.lang.Object

com.lightstreamer.adapters.remote.Server

Direct Known Subclasses:

DataProviderServer, MetadataProviderServer

public abstract class Server
extends java.lang.Object

A generic server object, which can run a Remote Data or Metadata Adapter and connect it to the Proxy Adapter running on Lightstreamer Server.
The object should be provided with a suitable Adapter instance and with suitable initialization parameters and established connections, then activated through start() and finally disposed through close(). Further reuse of the same instance is not supported.

Constructor Summary

Constructors

Constructor and Description
Server()

Method Summary

Modifier and Type	Method and Description
void	close() Stops the management of the Remote Adapter and destroys the threads used by this Server.
ExceptionHandler	getExceptionHandler() Gets the handler for error conditions occurring on the Remote Server.
java.lang.String	getName() Gets the name, used for logging purposes, associated to the Server instance.
java.io.OutputStream	getNotifyStream() Gets the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter.
java.io.OutputStream	getReplyStream() Gets the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.
java.io.InputStream	getRequestStream() Gets the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter.
void	setExceptionHandler(ExceptionHandler handler) Sets the handler for error conditions occurring on the Remote Server.
static void	setLoggerProvider(LoggerProvider loggerProvider) Sets the LoggerProvider instance that will be used by the classes of the library to obtain Logger instances used to propagate internal logging.
void	setName(java.lang.String name) Sets a name for the Server instance; used for logging purposes.
void	setNotifyStream(java.io.OutputStream outputStream) Sets the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter.
void	setReplyStream(java.io.OutputStream outputStream) Sets the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.
void	setRequestStream(java.io.InputStream inputStream) Sets the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter.
void	start() Starts the Remote Adapter.

Methods inherited from class java.lang.Object

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

Constructor Detail

Server

public Server()

Method Detail

setName

public final void setName(java.lang.String name)

Sets a name for the Server instance; used for logging purposes.

Parameters:

name - a name to identify the instance.

getName

public final java.lang.String getName()

Gets the name, used for logging purposes, associated to the Server instance.

Returns:

the name for the Server instance.

setRequestStream

public final void setRequestStream(java.io.InputStream inputStream)

Sets the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter.

Parameters:

inputStream - the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter

getRequestStream

public final java.io.InputStream getRequestStream()

Gets the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter.

Returns:

the stream used by the Proxy Adapter in order to forward the requests to the Remote Adapter

setReplyStream

public final void setReplyStream(java.io.OutputStream outputStream)

Sets the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.

Parameters:

outputStream - the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.

getReplyStream

public final java.io.OutputStream getReplyStream()

Gets the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.

Returns:

the stream used by the Remote Adapter in order to forward the answers to the Proxy Adapter.

setNotifyStream

public final void setNotifyStream(java.io.OutputStream outputStream)

Sets the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter. Currently not used and not needed by the Remote Metadata Adapter.

Parameters:

outputStream - the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter.

getNotifyStream

public final java.io.OutputStream getNotifyStream()

Gets the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter. Currently not used and not needed by the Remote Metadata Adapter.

Returns:

the stream used by the Remote Adapter in order to send asyncronous data to the Remote Adapter.

setExceptionHandler

public final void setExceptionHandler(ExceptionHandler handler)

Sets the handler for error conditions occurring on the Remote Server. By setting the handler, it's possible to override the default exception handling.

Parameters:

handler - the handler for error conditions occurring on the Remote Server.

getExceptionHandler

public final ExceptionHandler getExceptionHandler()

Gets the handler for error conditions occurring on the Remote Server.

Returns:

the handler for error conditions occurring on the Remote Server.

start

public final void start()
                 throws RemotingException,
                        DataProviderException,
                        MetadataProviderException

Starts the Remote Adapter. A connection to the Proxy Adapter is performed (as soon as one is available). Then, requests issued by the Proxy Adapter are received and forwarded to the Remote Adapter.

Throws:

RemotingException - An error occurred in the initialization phase. The adapter was not started.

DataProviderException - An error occurred in the initialization phase. The adapter was not started.

MetadataProviderException - An error occurred in the initialization phase. The adapter was not started.

close

public final void close()

Stops the management of the Remote Adapter and destroys the threads used by this Server. This instance can no longer be used.
The streams supplied to this instance are also closed.
Note that this does not stop the supplied Remote Adapter, as no close method is available in the Remote Adapter interface. If the process is not terminating, then the Remote Adapter cleanup should be performed by accessing the supplied Adapter instance directly and calling custom methods.

setLoggerProvider

public static void setLoggerProvider(LoggerProvider loggerProvider)

Sets the LoggerProvider instance that will be used by the classes of the library to obtain Logger instances used to propagate internal logging. Providing a new provider to the library permits to consume the log produced through custom Logger implementation.
As soon as a new LoggerProvider is provided all the instances of Logger already in use in the library are discarded and substituted with instanced obtained from this new instance. If a null value is provided, the default consumers, that discard all the log, are enabled.

Parameters:

loggerProvider - Will be responsible to provide Logger instances to the various classes of the library.