public class ServerMessageRouter extends MessageRouter
ServerSocketChannel
.
This class is useful for components that must accept incoming requests from
clients.changeInterest, DEFAULT_READ_BUFFER_SIZE, DEFAULT_WRITE_QUEUE_SIZE, logger, online, PREFIX_SZ, READ_BUFFER_PROPERTY, readBufferSize, selector, WRITE_QUEUE_PROPERTY, writeQueueSize
Constructor and Description |
---|
ServerMessageRouter() |
ServerMessageRouter(int readBufferSize,
int maxWriteQueueSize) |
Modifier and Type | Method and Description |
---|---|
void |
close(int port) |
void |
listen(int port)
Initializes the server socket channel for incoming client connections and
begins listening for messages.
|
void |
shutdown()
Closes the server socket channel and stops processing incoming
messages.
|
accept, addListener, connect, disconnect, dispatchConnect, dispatchDisconnect, dispatchMessage, getClientString, getDestination, isOnline, processIncomingMessage, processSelectionKeys, read, readPrefix, run, sendMessage, updateInterestOps, wrapWithPrefix
public ServerMessageRouter()
public ServerMessageRouter(int readBufferSize, int maxWriteQueueSize)
public void listen(int port) throws java.io.IOException
port
- The port to listen for messages on.java.io.IOException
public void shutdown() throws java.io.IOException
java.io.IOException
public void close(int port) throws java.io.IOException
port
- Port number to stop listening on.java.io.IOException