Module id.ICE

Package id.ICE

Class MessageServer

Object

MessageServer

All Implemented Interfaces:

AutoCloseable, Runnable

public class MessageServer
extends Object
implements Runnable, AutoCloseable

Runs ICE server on a given port and manages all interaction between clients and MessageService.

Constructor Summary

Constructors

Constructor	Description
MessageServer(MessageService service, MessageScanner scanner)

Method Summary

Modifier and Type	Method	Description
void	close()	Calling close on server which is not started has no effect
void	run()	Starts ICE server.
MessageServer	withNumberOfThreads(int threads)
MessageServer	withPort(int port)	Port where to run the server.

Methods inherited from class Object

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

Constructor Details

MessageServer

public MessageServer(MessageService service,
 MessageScanner scanner)

Parameters:

service - message service implementation which will process all incoming messages

scanner - scanner for messages to use

Method Details

withPort

public MessageServer withPort(int port)

Port where to run the server.

See Also:

• for default port.

withNumberOfThreads

public MessageServer withNumberOfThreads(int threads)

run

public void run()

Starts ICE server.

It opens a given port and starts to accept connections. For each new incoming connection it will run a looper.

Specified by:

run in interface Runnable

close

public void close()
           throws Exception

Calling close on server which is not started has no effect

Specified by:

close in interface AutoCloseable

Throws:

Exception