Package kieker.monitoring.writer.amqp

Class ChunkingAmqpWriter

java.lang.Object

kieker.monitoring.writer.amqp.ChunkingAmqpWriter

All Implemented Interfaces:

IRawDataWriter

public class ChunkingAmqpWriter
extends 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	Description
static final String	CONFIG_EXCHANGENAME	The name of the configuration property for the AMQP exchange name.
static final String	CONFIG_HEARTBEAT	The name of the configuration property for the heartbeat timeout.
static final String	CONFIG_QUEUENAME	The name of the configuration property for the AMQP queue name.
static final String	CONFIG_URI	The name of the configuration property for the server URI.

Constructor Summary

Constructors

Constructor	Description
ChunkingAmqpWriter(Configuration configuration)

Method Summary

Modifier and Type	Method	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(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 Details

CONFIG_URI

public static final String CONFIG_URI

The name of the configuration property for the server URI.

CONFIG_EXCHANGENAME

public static final String CONFIG_EXCHANGENAME

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

CONFIG_QUEUENAME

public static final String CONFIG_QUEUENAME

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

CONFIG_HEARTBEAT

public static final String CONFIG_HEARTBEAT

The name of the configuration property for the heartbeat timeout.

Constructor Details

ChunkingAmqpWriter

public ChunkingAmqpWriter(Configuration configuration)
                   throws KeyManagementException,
NoSuchAlgorithmException,
URISyntaxException,
IOException,
TimeoutException

Throws:

KeyManagementException

NoSuchAlgorithmException

URISyntaxException

IOException

TimeoutException

Method Details

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(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