Package kieker.monitoring.writer.amqp

Class AmqpWriter

java.lang.Object
kieker.monitoring.writer.AbstractMonitoringWriter
kieker.monitoring.writer.amqp.AmqpWriter
All Implemented Interfaces:
IRegistryListener<java.lang.String>
public class AmqpWriter
extends AbstractMonitoringWriter
implements IRegistryListener<java.lang.String>
Monitoring record writer which sends records using the AMQP protocol to a message queue.
Since:
1.12
Author:
Holger Knoche, Christian Wulf

  • Field Summary

    Fields 
    Modifier and Type Field Description
    static java.lang.String CONFIG_EXCHANGENAME
    The name of the configuration property for the AMQP exchange name.
    static java.lang.String CONFIG_HEARTBEAT
    The name of the configuration property for the heartbeat timeout.
    static java.lang.String CONFIG_QUEUENAME
    The name of the configuration property for the AMQP queue name.
    static java.lang.String CONFIG_URI
    The name of the configuration property for the server URI.
    static byte REGISTRY_RECORD_ID
    ID for registry records.
    static byte REGULAR_RECORD_ID
    ID for regular records.

    Fields inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

    configuration

  • Constructor Summary

    Constructors 
    Constructor Description
    AmqpWriter​(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.

    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