Package kieker.analysis.plugin.reader.amqp

Class AmqpReader

java.lang.Object
kieker.analysis.analysisComponent.AbstractAnalysisComponent
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.reader.AbstractReaderPlugin
kieker.analysis.plugin.reader.AbstractStringRegistryReaderPlugin
kieker.analysis.plugin.reader.amqp.AmqpReader
All Implemented Interfaces:
IAnalysisComponent, IPlugin, IReaderPlugin
@Deprecated
public final class AmqpReader
extends AbstractStringRegistryReaderPlugin
Deprecated.
since 1.15.1 old plugin api
Reader plugin that reads monitoring records from an AMQP queue.
Since:
1.12
Author:
Holger Knoche

  • Field Details

  • Constructor Details

    • AmqpReader

      public AmqpReader​(Configuration configuration, IProjectContext projectContext)
      Deprecated.
      Creates a new AMQP reader with the given configuration in the given context.
      Parameters:
      configuration - The configuration for this reader
      projectContext - The project context for this component

  • Method Details

    • init

      public boolean init()
      Deprecated.
      Description copied from class: AbstractReaderPlugin
      Initiates the start of a component. This method is called once when a AnalysisController's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) asynchronous thread(s) in this method.
      Specified by:
      init in interface IPlugin
      Overrides:
      init in class AbstractStringRegistryReaderPlugin
      Returns:
      true on success; false otherwise.

    • getCurrentConfiguration

      public Configuration getCurrentConfiguration()
      Deprecated.
      Description copied from class: AbstractAnalysisComponent
      This method should deliver a Configuration object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.
      Specified by:
      getCurrentConfiguration in interface IAnalysisComponent
      Specified by:
      getCurrentConfiguration in interface IPlugin
      Specified by:
      getCurrentConfiguration in class AbstractAnalysisComponent
      Returns:
      A completely filled configuration object.

    • read

      public boolean read()
      Deprecated.
      Description copied from interface: IReaderPlugin
      Starts the reader. This method is intended to be a blocking operation, i.e., it is assumed that reading has finished before this method returns. The method should indicate an error by the return value false. In asynchronous scenarios, the IPlugin.terminate(boolean) method can be used to initiate the termination of this method.
      Returns:
      true if reading was successful; false if an error occurred

    • terminate

      public void terminate​(boolean error)
      Deprecated.
      Description copied from interface: IPlugin
      Initiates a termination of the plugin. This method is only used by the framework and should not be called manually. Use the method AnalysisController.terminate(boolean) instead. After receiving this notification, the plugin should terminate any running methods, e.g., read for readers.
      Parameters:
      error - Determines whether the plugin is terminated due to an error or not.

    • deliverRecord

      protected void deliverRecord​(IMonitoringRecord monitoringRecord)
      Deprecated.
      Description copied from class: AbstractStringRegistryReaderPlugin
      Delivers the given record to the appropriate output port(s).
      Specified by:
      deliverRecord in class AbstractStringRegistryReaderPlugin
      Parameters:
      monitoringRecord - The monitoring record to deliver