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.StringCONFIG_BUFFERSIZEconfiguration key for the size of therecordBuffer.static java.lang.StringCONFIG_FLUSHconfiguration key forflush.static java.lang.StringCONFIG_HOSTNAMEconfiguration key for the hostname.static java.lang.StringCONFIG_PORT1configuration key for the monitoring port.static java.lang.StringCONFIG_PORT2configuration key for the registry port. -
Constructor Summary
Constructors Constructor Description DualSocketTcpWriter(Configuration configuration) -
Method Summary
Modifier and Type Method Description voidonNewRegistryEntry(java.lang.String value, int id)This event is fired after a new registry entry was registered.voidonStarting()This event fires when Kieker has been initialized and is ready to monitor.voidonTerminating()This event fires when Kieker has been notified to terminate.voidwriteMonitoringRecord(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:AbstractMonitoringWriterThis event fires when Kieker has been initialized and is ready to monitor. It is executed by theMonitoringWriterThreadjust before reading the writer queue.- Specified by:
onStartingin classAbstractMonitoringWriter
-
writeMonitoringRecord
Description copied from class:AbstractMonitoringWriterThis event fires when Kieker has received a new record.- Specified by:
writeMonitoringRecordin classAbstractMonitoringWriter
-
onNewRegistryEntry
public void onNewRegistryEntry(java.lang.String value, int id)Description copied from interface:IRegistryListenerThis event is fired after a new registry entry was registered.- Specified by:
onNewRegistryEntryin interfaceIRegistryListener<java.lang.String>- Parameters:
value- valueid- id
-
onTerminating
public void onTerminating()Description copied from class:AbstractMonitoringWriterThis event fires when Kieker has been notified to terminate. It is executed by theMonitoringWriterThreadjust after finishing the writer queue.- Specified by:
onTerminatingin classAbstractMonitoringWriter
-