kieker.tools.bridge.connector.tcp
Class TCPMultiServerPortListenerRunnable
java.lang.Object
kieker.tools.bridge.connector.tcp.TCPMultiServerPortListenerRunnable
- All Implemented Interfaces:
- Runnable
public class TCPMultiServerPortListenerRunnable
- extends Object
- implements Runnable
Runnable class implementing a thread listening for an incoming connection for monitoring data.
It then starts a connection thread handling the actual data transmissions.
- Since:
- 1.8
- Author:
- Reiner Jung
Method Summary |
void |
run()
Main loop of the port listener. |
void |
setActive(boolean active)
|
TCPMultiServerPortListenerRunnable
public TCPMultiServerPortListenerRunnable(int port,
BlockingQueue<IMonitoringRecord> recordQueue,
ConcurrentMap<Integer,LookupEntity> lookupEntityMap,
ExecutorService executor)
throws IOException
- Create a listener for the incoming port of the multi server.
- Parameters:
port
- IP port to listen torecordQueue
- the central queue for incoming data recordslookupEntityMap
- lookup map for IMonitoringRecord typesexecutor
- the thread pool
- Throws:
IOException
- when no server socket can be created
run
public void run()
- Main loop of the port listener.
- Specified by:
run
in interface Runnable
setActive
public void setActive(boolean active)
Copyright 2013 Kieker Project, http://kieker-monitoring.net>