kieker.monitoring.writer.amqp
Class AMQPWriter

java.lang.Object
  kieker.monitoring.writer.AbstractMonitoringWriter
      kieker.monitoring.writer.AbstractAsyncWriter
          kieker.monitoring.writer.amqp.AMQPWriter

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringWriter

public final class AMQPWriter
extends AbstractAsyncWriter

Monitoring record writer which sends records using the AMQP protocol to a message queue.

Since:

1.12

Author:

Holger Knoche

Field Summary

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.AbstractAsyncWriter

blockingQueue, CONFIG_BEHAVIOR, CONFIG_PRIORITIZED_QUEUESIZE, CONFIG_QUEUESIZE, CONFIG_SHUTDOWNDELAY, prioritizedBlockingQueue

Fields inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

monitoringController

Constructor Summary

AMQPWriter(Configuration configuration)
Creates a new instance of this class using the given parameters.

Method Summary

protected void

init() Implementing classes should indicate an initialization error by throwing an Exception.

Methods inherited from class kieker.monitoring.writer.AbstractAsyncWriter

addWorker, getDefaultConfiguration, newMonitoringRecord, newMonitoringRecordNonBlocking, terminate, toString

Methods inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

setController

Methods inherited from class java.lang.Object

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

Field Detail

REGISTRY_RECORD_ID

public static final byte REGISTRY_RECORD_ID

ID for registry records.

See Also:

Constant Field Values

REGULAR_RECORD_ID

public static final byte REGULAR_RECORD_ID

ID for regular records.

See Also:

Constant Field Values

CONFIG_URI

public static final java.lang.String CONFIG_URI

The name of the configuration property for the server URI.

CONFIG_EXCHANGENAME

public static final java.lang.String CONFIG_EXCHANGENAME

The name of the configuration property for the AMQP exchange name.

CONFIG_QUEUENAME

public static final java.lang.String CONFIG_QUEUENAME

The name of the configuration property for the AMQP queue name.

CONFIG_HEARTBEAT

public static final java.lang.String CONFIG_HEARTBEAT

The name of the configuration property for the heartbeat timeout.

Constructor Detail

AMQPWriter

public AMQPWriter(Configuration configuration)

Creates a new instance of this class using the given parameters.

Parameters:

configuration - The configuration for this writer.

Method Detail

init

protected void init()
             throws java.lang.Exception

Description copied from class: AbstractMonitoringWriter

Implementing classes should indicate an initialization error by throwing an Exception.

Specified by:

init in class AbstractMonitoringWriter

Throws:

java.lang.Exception - If something during the initialization went wrong.