kieker.analysis.plugin.reader.amqp

Class ChunkingAmqpReader

java.lang.Object

kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader

All Implemented Interfaces:

IRawDataReader

public class ChunkingAmqpReader
extends java.lang.Object
implements IRawDataReader

AMQP reader plugin that supports chunking using 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_PROPERTY_HEARTBEAT The name of the configuration property for the heartbeat timeout.
static java.lang.String	CONFIG_PROPERTY_QUEUENAME The name of the configuration property for the AMQP queue name.
static java.lang.String	CONFIG_PROPERTY_URI The name of the configuration property for the server URI.

Constructor Summary

Constructors

Constructor and Description
ChunkingAmqpReader(Configuration configuration, IRawDataProcessor processor)

Method Summary

Modifier and Type	Method and Description
Outcome	onInitialization() Event handler that is called before any records are read.
Outcome	onTermination() Event handler that is called when the reader is supposed to terminate.
Outcome	read() Starts the read operation.

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_PROPERTY_URI

public static final java.lang.String CONFIG_PROPERTY_URI

The name of the configuration property for the server URI.

See Also:

Constant Field Values

CONFIG_PROPERTY_QUEUENAME

public static final java.lang.String CONFIG_PROPERTY_QUEUENAME

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

See Also:

Constant Field Values

CONFIG_PROPERTY_HEARTBEAT

public static final java.lang.String CONFIG_PROPERTY_HEARTBEAT

The name of the configuration property for the heartbeat timeout.

See Also:

Constant Field Values

Constructor Detail

ChunkingAmqpReader

public ChunkingAmqpReader(Configuration configuration,
                          IRawDataProcessor processor)

Method Detail

onInitialization

public Outcome onInitialization()

Description copied from interface: IRawDataReader

Event handler that is called before any records are read.

Specified by:

onInitialization in interface IRawDataReader

Returns:

The outcome of the initialization

read

public Outcome read()

Description copied from interface: IRawDataReader

Starts the read operation.

Specified by:

read in interface IRawDataReader

Returns:

The outcome of the read operation

onTermination

public Outcome onTermination()

Description copied from interface: IRawDataReader

Event handler that is called when the reader is supposed to terminate.

Specified by:

onTermination in interface IRawDataReader

Returns:

The outcome of the termination