kieker.analysis.plugin.reader.tcp

Class AbstractRecordTcpReader

java.lang.Object

kieker.monitoring.core.controller.tcp.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.monitoring.core.controller.tcp.AbstractTcpReader

logger

Constructor Summary

Constructors

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

Method Summary

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

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

AbstractRecordTcpReader

public AbstractRecordTcpReader(org.slf4j.Logger logger,
                               ReaderRegistry<java.lang.String> stringRegistry)

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

Parameters:

logger - logger for the TCP reader

stringRegistry - string registry for the reader

AbstractRecordTcpReader

public AbstractRecordTcpReader(int port,
                               int bufferCapacity,
                               org.slf4j.Logger logger,
                               ReaderRegistry<java.lang.String> stringRegistry,
                               CachedRecordFactoryCatalog recordFactories)

Parameters:

port - accept connections on this port

bufferCapacity - capacity of the receiving buffer

logger - logger for the TCP reader

stringRegistry - string registry for the reader

recordFactories - cache for record factories

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)