kieker.monitoring.writer.amqp

Class ChunkingAmqpWriter

java.lang.Object

kieker.monitoring.writer.amqp.ChunkingAmqpWriter

All Implemented Interfaces:

IRawDataWriter

public class ChunkingAmqpWriter
extends java.lang.Object
implements IRawDataWriter

AMQP writer plugin that supports chunking via the new raw data I/O infrastructure.

Since:

1.13

Author:

Holger Knoche

Field Summary

Fields

Modifier and Type	Field and 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.

Constructor Summary

Constructors

Constructor and Description
ChunkingAmqpWriter(Configuration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
void	onInitialization() Called by the collector during initialization (before any records are written).
void	onTermination() Called by the collector upon termination (after remaining records have been flushed).
void	writeData(java.nio.ByteBuffer buffer, int offset, int length) Writes raw data contained in the given byte buffer.

Methods inherited from class java.lang.Object

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

Field Detail

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

ChunkingAmqpWriter

public ChunkingAmqpWriter(Configuration configuration)
                   throws java.security.KeyManagementException,
                          java.security.NoSuchAlgorithmException,
                          java.net.URISyntaxException,
                          java.io.IOException,
                          java.util.concurrent.TimeoutException

Throws:

java.security.KeyManagementException

java.security.NoSuchAlgorithmException

java.net.URISyntaxException

java.io.IOException

java.util.concurrent.TimeoutException

Method Detail

onInitialization

public void onInitialization()

Description copied from interface: IRawDataWriter

Called by the collector during initialization (before any records are written).

Specified by:

onInitialization in interface IRawDataWriter

onTermination

public void onTermination()

Description copied from interface: IRawDataWriter

Called by the collector upon termination (after remaining records have been flushed).

Specified by:

onTermination in interface IRawDataWriter

writeData

public void writeData(java.nio.ByteBuffer buffer,
             int offset,
             int length)

Description copied from interface: IRawDataWriter

Writes raw data contained in the given byte buffer.

Specified by:

writeData in interface IRawDataWriter

Parameters:

buffer - The buffer containing the data

offset - The offset in the buffer where the data starts

length - The length of the data to write