org.processmining.operationalsupport.server

Class OSService

java.lang.Object

java.util.Observable

org.processmining.operationalsupport.server.TransientObservable

org.processmining.operationalsupport.server.OSService

All Implemented Interfaces:

org.processmining.framework.util.socket.ServiceHandler

Direct Known Subclasses:

OSServicePOM

public class OSService
extends TransientObservable
implements org.processmining.framework.util.socket.ServiceHandler

Author:

mwesterg This class overwrites the Observable interface itself, as we must not serialize observers (visualizers) and XStream does not use writeObject, so we cannot prevent that otherwise.

Field Summary

Fields

Modifier and Type	Field and Description
protected OSXMLConverter	converter

Constructor Summary

Constructors

Constructor and Description
OSService(int port)

Method Summary

Modifier and Type	Method and Description
void	addProvider(Provider p)
java.util.logging.Logger	getLogger()
int	getPort()
java.util.Collection<Session>	getSessions()
void	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, java.io.BufferedReader in, java.io.PrintWriter out) Invoked whenever a client connects to the service.
Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, ComparisonQuery<?,?> request)
Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, CreateSession<?> request)
SessionDestroyed	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, DestroySession request)
Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, PredictQuery<?,?> request)
protected ProtocolHelper.Message	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, ProtocolHelper.Message message)
Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, RecommendQuery<?,?,?> request)
protected Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, Request request)
Response	handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment, SimpleQuery<?> request)
protected void	individual(java.lang.String string)
boolean	isRunning()
protected void	log(java.lang.String string)
void	notifyObservers()
java.util.Set<Provider>	providers()
protected java.lang.Object	readResolve()
void	removeProvider(Provider p)
void	setPort(int port)
void	start(java.util.concurrent.Executor executor)
void	stop()
java.lang.String	toString()
protected void	trace(java.lang.String string)
protected void	traceMessage(java.lang.String string)

Methods inherited from class org.processmining.operationalsupport.server.TransientObservable

addObserver, deleteObserver, notifyObservers, setChanged

Methods inherited from class java.util.Observable

clearChanged, countObservers, deleteObservers, hasChanged

Methods inherited from class java.lang.Object

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

Field Detail

converter

protected transient OSXMLConverter converter

Constructor Detail

OSService

public OSService(int port)

Parameters:

port -

Method Detail

addProvider

public void addProvider(Provider p)

getLogger

public java.util.logging.Logger getLogger()

getPort

public int getPort()

Returns:

the port

getSessions

public java.util.Collection<Session> getSessions()

handleRequest

public void handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                          java.io.BufferedReader in,
                          java.io.PrintWriter out)
                   throws java.io.IOException

Description copied from interface: org.processmining.framework.util.socket.ServiceHandler

Invoked whenever a client connects to the service.

Specified by:

handleRequest in interface org.processmining.framework.util.socket.ServiceHandler

Parameters:

environment - is the registered environment of the service. A handler can use this parameter to, for example, log messages.

in - is the buffer from which the client's request can be read.

out - is the buffer where a possible response to the client can be written.

Throws:

java.io.IOException

handleRequest

public Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                              ComparisonQuery<?,?> request)

handleRequest

public Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                              CreateSession<?> request)

handleRequest

public SessionDestroyed handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                                      DestroySession request)

handleRequest

public Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                              PredictQuery<?,?> request)

handleRequest

public Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                              RecommendQuery<?,?,?> request)

handleRequest

public Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                              SimpleQuery<?> request)

Parameters:

environment -

request -

Returns:

isRunning

public boolean isRunning()

Returns:

the running

notifyObservers

public void notifyObservers()

Overrides:

notifyObservers in class java.util.Observable

providers

public java.util.Set<Provider> providers()

removeProvider

public void removeProvider(Provider p)

setPort

public void setPort(int port)

Parameters:

port - the port to set

start

public void start(java.util.concurrent.Executor executor)
           throws java.io.IOException

Throws:

java.io.IOException

stop

public void stop()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

handleRequest

protected ProtocolHelper.Message handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                                               ProtocolHelper.Message message)

handleRequest

protected Response handleRequest(org.processmining.framework.util.socket.ServiceEnvironment environment,
                                 Request request)

individual

protected void individual(java.lang.String string)

log

protected void log(java.lang.String string)

readResolve

protected java.lang.Object readResolve()

Overrides:

readResolve in class TransientObservable

trace

protected void trace(java.lang.String string)

traceMessage

protected void traceMessage(java.lang.String string)