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 java.lang.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 java.lang.String CONFIG_PROPERTY_HEARTBEAT
    Deprecated.
    The name of the configuration property for the heartbeat timeout.
    static java.lang.String CONFIG_PROPERTY_QUEUENAME
    Deprecated.
    The name of the configuration property for the AMQP queue name.
    static java.lang.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