kieker.tools.bridge.connector.tcp
Class TCPMultiServerPortListenerRunnable
java.lang.Object
kieker.tools.bridge.connector.tcp.TCPMultiServerPortListenerRunnable
- All Implemented Interfaces:
- java.lang.Runnable
public class TCPMultiServerPortListenerRunnable
- extends java.lang.Object
- implements java.lang.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
Constructor Summary |
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. |
Method Summary |
void |
run()
Main loop of the port listener. |
void |
setActive(boolean active)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TCPMultiServerPortListenerRunnable
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
- 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:
java.io.IOException
- when no server socket can be created
run
public void run()
- Main loop of the port listener.
- Specified by:
run
in interface java.lang.Runnable
setActive
public void setActive(boolean active)
Copyright 2015 Kieker Project, http://kieker-monitoring.net