public class TCPMultiServerPortListenerRunnable
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
TCPMultiServerPortListenerRunnable(int port,
java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue,
java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
java.util.concurrent.ExecutorService executor)
Create a listener for the incoming port of the multi server.
|
public TCPMultiServerPortListenerRunnable(int port, java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue, java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap, java.util.concurrent.ExecutorService executor) throws java.io.IOException
port
- IP port to listen torecordQueue
- the central queue for incoming data recordslookupEntityMap
- lookup map for IMonitoringRecord typesexecutor
- the thread pooljava.io.IOException
- when no server socket can be createdCopyright 2017 Kieker Project, http://kieker-monitoring.net