kieker.tools.bridge.connector.tcp
Class TCPMultiServerConnectionRunnable

java.lang.Object
  kieker.tools.bridge.connector.tcp.TCPMultiServerConnectionRunnable

All Implemented Interfaces:

java.lang.Runnable

public class TCPMultiServerConnectionRunnable
extends java.lang.Object
implements java.lang.Runnable

Handles one TCP connection for the multi server.

Since:

1.8

Author:

Reiner Jung

Constructor Summary

TCPMultiServerConnectionRunnable(java.net.Socket socket, java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap, java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue)
Create a service thread.

Method Summary

boolean	isActive()
void	run() Main loop of the connection runnable.
void	setActive(boolean active)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TCPMultiServerConnectionRunnable

public TCPMultiServerConnectionRunnable(java.net.Socket socket,
                                        java.util.concurrent.ConcurrentMap<java.lang.Integer,LookupEntity> lookupEntityMap,
                                        java.util.concurrent.BlockingQueue<IMonitoringRecord> recordQueue)

Create a service thread.

Parameters:

socket - service socket

lookupEntityMap - map for constructor and parameter fields of records combined with the record id

recordQueue - Queue of the server to retrieve all deserialized records

Method Detail

run

public void run()

Main loop of the connection runnable.

Specified by:

run in interface java.lang.Runnable

isActive

public boolean isActive()

setActive

public void setActive(boolean active)