kieker.analysis.plugin.reader.tcp

Class AbstractRecordTcpReader

java.lang.Object

kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

kieker.analysis.plugin.reader.tcp.AbstractRecordTcpReader

All Implemented Interfaces:

java.lang.Runnable

public abstract class AbstractRecordTcpReader
extends AbstractTcpReader

Since:

1.13

Author:

Christian Wulf (chw)

Field Summary

Fields inherited from class kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

logger

Constructor Summary

Constructors

Constructor and Description
AbstractRecordTcpReader(int port, int bufferCapacity, Log logger, ILookup<java.lang.String> stringRegistry, CachedRecordFactoryCatalog recordFactories)
AbstractRecordTcpReader(Log logger, ILookup<java.lang.String> stringRegistry) Default constructor with port=10133 and bufferCapacity=65535 and new CachedRecordFactoryCatalog()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	onBufferReceived(java.nio.ByteBuffer buffer)
protected abstract void	onRecordReceived(IMonitoringRecord record)

Methods inherited from class kieker.analysis.plugin.reader.tcp.util.AbstractTcpReader

getPort, run, terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractRecordTcpReader

public AbstractRecordTcpReader(Log logger,
                       ILookup<java.lang.String> stringRegistry)

Default constructor with port=10133 and bufferCapacity=65535 and new CachedRecordFactoryCatalog()

AbstractRecordTcpReader

public AbstractRecordTcpReader(int port,
                       int bufferCapacity,
                       Log logger,
                       ILookup<java.lang.String> stringRegistry,
                       CachedRecordFactoryCatalog recordFactories)

Parameters:

port - accept connections on this port

bufferCapacity - capacity of the receiving buffer

Method Detail

onBufferReceived

protected final 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.

onRecordReceived

protected abstract void onRecordReceived(IMonitoringRecord record)