public class ParallelMessageRouter
extends java.lang.Object
ClientMessageRouter
and a
ServerMessageRouter
instance, meaning outgoing and incoming messages
are processed by separate threads (in parallel).Constructor and Description |
---|
ParallelMessageRouter() |
ParallelMessageRouter(int readBufferSize,
int maxWriteQueueSize) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(MessageListener listener) |
void |
listen(int port) |
void |
sendMessage(NetworkDestination destination,
MendelMessage message) |
void |
shutdown() |
public ParallelMessageRouter() throws java.io.IOException
java.io.IOException
public ParallelMessageRouter(int readBufferSize, int maxWriteQueueSize) throws java.io.IOException
java.io.IOException
public void listen(int port) throws java.io.IOException
java.io.IOException
public void sendMessage(NetworkDestination destination, MendelMessage message) throws java.io.IOException
java.io.IOException
public void shutdown() throws java.io.IOException
java.io.IOException
public void addListener(MessageListener listener)