Package kieker.monitoring.writer.tcp

Class SingleSocketTcpWriter

java.lang.Object

kieker.monitoring.writer.AbstractMonitoringWriter

kieker.monitoring.writer.tcp.SingleSocketTcpWriter

All Implemented Interfaces:

IRegistryListener<String>

public class SingleSocketTcpWriter
extends AbstractMonitoringWriter
implements IRegistryListener<String>

Represents a monitoring writer which serializes records via TCP to a given host:port.

Since:

1.13

Author:

Christian Wulf

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIG_BUFFERSIZE	configuration key for the size of the buffer.
static final String	CONFIG_CONN_TIMEOUT_IN_MS	configuration key for connectionTimeoutInMs.
static final String	CONFIG_FLUSH	configuration key for flush.
static final String	CONFIG_HOSTNAME	configuration key for the hostname.
static final String	CONFIG_PORT	configuration key for the port.
static final String	PREFIX	This writer can be configured by the configuration file "kieker.properties".

Fields inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

configuration

Constructor Summary

Constructors

Constructor	Description
SingleSocketTcpWriter(Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	onNewRegistryEntry(String value, int id)	This event is fired after a new registry entry was registered.
void	onStarting()	This event fires when Kieker has been initialized and is ready to monitor.
void	onTerminating()	This event fires when Kieker has been notified to terminate.
void	writeMonitoringRecord(IMonitoringRecord monitoringRecord)	This event fires when Kieker has received a new record.

Methods inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

toString

Methods inherited from class java.lang.Object

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

Field Details

PREFIX

public static final String PREFIX

This writer can be configured by the configuration file "kieker.properties". For this purpose, it uses this prefix for all configuration keys.

CONFIG_HOSTNAME

public static final String CONFIG_HOSTNAME

configuration key for the hostname.

CONFIG_PORT

public static final String CONFIG_PORT

configuration key for the port.

CONFIG_BUFFERSIZE

public static final String CONFIG_BUFFERSIZE

configuration key for the size of the buffer.

CONFIG_FLUSH

public static final String CONFIG_FLUSH

configuration key for flush.

CONFIG_CONN_TIMEOUT_IN_MS

public static final String CONFIG_CONN_TIMEOUT_IN_MS

configuration key for connectionTimeoutInMs.

Constructor Details

SingleSocketTcpWriter

public SingleSocketTcpWriter(Configuration configuration)
                      throws IOException

Throws:

IOException

Method Details

onStarting

public void onStarting()

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has been initialized and is ready to monitor. It is executed by the MonitoringWriterThread just before reading the writer queue.

Specified by:

onStarting in class AbstractMonitoringWriter

writeMonitoringRecord

public void writeMonitoringRecord(IMonitoringRecord monitoringRecord)

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has received a new record.

Specified by:

writeMonitoringRecord in class AbstractMonitoringWriter

onNewRegistryEntry

public void onNewRegistryEntry(String value,
 int id)

Description copied from interface: IRegistryListener

This event is fired after a new registry entry was registered.

Specified by:

onNewRegistryEntry in interface IRegistryListener<String>

Parameters:

value - value

id - id

onTerminating

public void onTerminating()

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has been notified to terminate. It is executed by the MonitoringWriterThread just after finishing the writer queue.

Specified by:

onTerminating in class AbstractMonitoringWriter