kieker.monitoring.core.controller.tcp

Class SingleSocketRecordReader

java.lang.Object

kieker.monitoring.core.controller.tcp.AbstractTcpReader

kieker.monitoring.core.controller.tcp.SingleSocketRecordReader

All Implemented Interfaces:

java.lang.Runnable

public class SingleSocketRecordReader
extends AbstractTcpReader

Represents a TCP reader which reads and reconstructs Kieker records from a single TCP stream.

Since:

1.13

Author:

Christian Wulf (chw)

Field Summary

Fields inherited from class kieker.monitoring.core.controller.tcp.AbstractTcpReader

logger

Constructor Summary

Constructors

Constructor and Description
SingleSocketRecordReader(int port, int bufferCapacity, org.slf4j.Logger logger, boolean respawn, IRecordReceivedListener listener) Create single socket reader.
SingleSocketRecordReader(int port, int bufferCapacity, org.slf4j.Logger logger, IRecordReceivedListener listener) Create single socket reader.

Method Summary

Modifier and Type	Method and Description
protected boolean	onBufferReceived(java.nio.ByteBuffer buffer)

Methods inherited from class kieker.monitoring.core.controller.tcp.AbstractTcpReader

getPort, run, terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleSocketRecordReader

public SingleSocketRecordReader(int port,
                                int bufferCapacity,
                                org.slf4j.Logger logger,
                                IRecordReceivedListener listener)

Create single socket reader.

Parameters:

port - port to listen to

bufferCapacity - buffer capacity

logger - logger to be used

listener - listener to trigger on received records

SingleSocketRecordReader

public SingleSocketRecordReader(int port,
                                int bufferCapacity,
                                org.slf4j.Logger logger,
                                boolean respawn,
                                IRecordReceivedListener listener)

Create single socket reader.

Parameters:

port - port to listen to

bufferCapacity - buffer capacity

logger - logger to be used

respawn - true when reader should respawn after lost connection

listener - listener to trigger on received records

Method Detail

onBufferReceived

protected boolean onBufferReceived(java.nio.ByteBuffer buffer)

Specified by:

onBufferReceived in class AbstractTcpReader

Parameters:

buffer - to be read from

Returns:

• true when there were enough bytes to perform the read operation
• false otherwise. In this case, the buffer is reset, compacted, and filled with new content.