public class PacketServer extends PropertyContainer
| Modifier and Type | Class and Description |
|---|---|
private class |
PacketServer.ReceiverThread
The reciever thread waits on the input line until data comes available.
|
private class |
PacketServer.SenderThread
This thread performs the sending of a message.
|
class |
PacketServer.Single |
static class |
PacketServer.Test
This class connects to the DCP server as stated in the command line
properties, tries to connects and sends a NOP command.
|
| Modifier and Type | Field and Description |
|---|---|
private boolean |
cancel |
private static long |
DEFRECEIVERWAIT
Default check time for incoming transmissions.
|
private static long |
DEFSENDERWAIT
Default wake-up period for sender, defines max time to cancel.
|
static String |
KEY_RECEIVERWAIT
The wait period for a receiver to check its stream.
|
static String |
KEY_SENDERWAIT
The wait period for a sender to check its queue.
|
private Deque<Message> |
outqueue
This is the dequeue used on output, no input queue necessary.
|
KEY_LISTSEPARATOR, KEY_MAPKEYVALUECHAR, KEY_MAPSEPARATORCONFIG, KEY_CLASS| Constructor and Description |
|---|
PacketServer(Map<String,String> prop) |
| Modifier and Type | Method and Description |
|---|---|
void |
startServe() |
augment, augment, augment, augment, augment, clone, defaultBoolean, defaultChar, defaultDouble, defaultFloat, defaultInt, defaultLong, defaultObject, defaultObject, defaultProperties, defaultProperty, getAsBoolean, getAsChar, getAsDouble, getAsEnums, getAsFloat, getAsInt, getAsList, getAsLong, getAsMap, getAsMap, getAsObject, getAsObject, getProperties, getProperty, has, initProperties, isNew, parseObject, parseObject, reload, reload, removeProperty, requires, rescanned, setObject, setProperties, setProperty, stringProperties, toStringpublic static final String KEY_SENDERWAIT
public static final String KEY_RECEIVERWAIT
private static final long DEFSENDERWAIT
private static final long DEFRECEIVERWAIT
private Deque<Message> outqueue
private boolean cancel
public void startServe()
throws IOException
IOException