36 |
|
* |
37 |
|
* @param port The port that the server will listen on. |
38 |
|
* @param queue A Queue to utilise |
39 |
+ |
* @param queueMonitorInterval The interval at which to monitor Queues |
40 |
|
*/ |
41 |
< |
public TCPClientListener(int port, PacketSorter packetSorter) { |
41 |
> |
public TCPClientListener(int port, PacketSorter packetSorter, int queueMonitorInterval) { |
42 |
|
_port = port; |
43 |
|
_packetSorter = packetSorter; |
44 |
+ |
_queueMonitorInterval = queueMonitorInterval; |
45 |
|
_logger.write(toString(), Logger.SYSINIT, "started"); |
46 |
|
} |
47 |
|
|
92 |
|
if(run){ |
93 |
|
try { |
94 |
|
// start up a ControlHandler to chat to the new Client |
95 |
< |
TCPControlHandler ctl = new TCPControlHandler(hostSocket, _packetSorter); |
95 |
> |
TCPControlHandler ctl = new TCPControlHandler(hostSocket, _packetSorter, _queueMonitorInterval); |
96 |
|
ctl.start(); |
97 |
|
} catch (IOException e) { |
98 |
|
_logger.write(toString(), Logger.ERROR, e.toString()); |
151 |
|
* A reference to the PacketSorter. |
152 |
|
*/ |
153 |
|
private PacketSorter _packetSorter; |
154 |
< |
|
154 |
> |
|
155 |
> |
/** |
156 |
> |
* The interval at which to monitor Queues. |
157 |
> |
*/ |
158 |
> |
private int _queueMonitorInterval; |
159 |
|
//---STATIC ATTRIBUTES--- |
160 |
|
|
161 |
|
} |