Package kieker.analysis.plugin.reader.amqp

Class ChunkingAmqpReader

java.lang.Object

kieker.analysis.plugin.reader.amqp.ChunkingAmqpReader

All Implemented Interfaces:

IRawDataReader

@Deprecated
public class ChunkingAmqpReader
extends Object
implements IRawDataReader

Deprecated.

since 1.15.1 old plugin api

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	Description
static final String	CONFIG_PROPERTY_HEARTBEAT	Deprecated. The name of the configuration property for the heartbeat timeout.
static final String	CONFIG_PROPERTY_QUEUENAME	Deprecated. The name of the configuration property for the AMQP queue name.
static final String	CONFIG_PROPERTY_URI	Deprecated. The name of the configuration property for the server URI.

Constructor Summary

Constructors

Constructor	Description
ChunkingAmqpReader(Configuration configuration, IRawDataProcessor processor)	Deprecated.

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

CONFIG_PROPERTY_URI

public static final String CONFIG_PROPERTY_URI

Deprecated.

The name of the configuration property for the server URI.

See Also:

• Constant Field Values

CONFIG_PROPERTY_QUEUENAME

public static final String CONFIG_PROPERTY_QUEUENAME

Deprecated.

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

See Also:

• Constant Field Values

CONFIG_PROPERTY_HEARTBEAT

public static final String CONFIG_PROPERTY_HEARTBEAT

Deprecated.

The name of the configuration property for the heartbeat timeout.

See Also:

• Constant Field Values

Constructor Details

ChunkingAmqpReader

public ChunkingAmqpReader(Configuration configuration,
 IRawDataProcessor processor)

Deprecated.

Method Details

onInitialization

public Outcome onInitialization()

Deprecated.

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

Deprecated.

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

Deprecated.

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