Package kieker.monitoring.writer.tcp
Class DualSocketTcpWriter
java.lang.Object
kieker.monitoring.writer.AbstractMonitoringWriter
kieker.monitoring.writer.tcp.DualSocketTcpWriter
- All Implemented Interfaces:
IRegistryListener<java.lang.String>
public class DualSocketTcpWriter extends AbstractMonitoringWriter implements IRegistryListener<java.lang.String>
- Since:
- 1.13
- Author:
- "Christian Wulf"
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
CONFIG_BUFFERSIZE
configuration key for the size of therecordBuffer
.static java.lang.String
CONFIG_FLUSH
configuration key forflush
.static java.lang.String
CONFIG_HOSTNAME
configuration key for the hostname.static java.lang.String
CONFIG_PORT1
configuration key for the monitoring port.static java.lang.String
CONFIG_PORT2
configuration key for the registry port. -
Constructor Summary
Constructors Constructor Description DualSocketTcpWriter(Configuration configuration)
-
Method Summary
Modifier and Type Method Description void
onNewRegistryEntry(java.lang.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.
-
Field Details
-
CONFIG_HOSTNAME
public static final java.lang.String CONFIG_HOSTNAMEconfiguration key for the hostname. -
CONFIG_PORT1
public static final java.lang.String CONFIG_PORT1configuration key for the monitoring port. -
CONFIG_PORT2
public static final java.lang.String CONFIG_PORT2configuration key for the registry port. -
CONFIG_BUFFERSIZE
public static final java.lang.String CONFIG_BUFFERSIZEconfiguration key for the size of therecordBuffer
. -
CONFIG_FLUSH
public static final java.lang.String CONFIG_FLUSHconfiguration key forflush
.
-
-
Constructor Details
-
DualSocketTcpWriter
- Throws:
java.io.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 theMonitoringWriterThread
just before reading the writer queue.- Specified by:
onStarting
in classAbstractMonitoringWriter
-
writeMonitoringRecord
Description copied from class:AbstractMonitoringWriter
This event fires when Kieker has received a new record.- Specified by:
writeMonitoringRecord
in classAbstractMonitoringWriter
-
onNewRegistryEntry
public void onNewRegistryEntry(java.lang.String value, int id)Description copied from interface:IRegistryListener
This event is fired after a new registry entry was registered.- Specified by:
onNewRegistryEntry
in interfaceIRegistryListener<java.lang.String>
- Parameters:
value
- valueid
- id
-
onTerminating
public void onTerminating()Description copied from class:AbstractMonitoringWriter
This event fires when Kieker has been notified to terminate. It is executed by theMonitoringWriterThread
just after finishing the writer queue.- Specified by:
onTerminating
in classAbstractMonitoringWriter
-