Package kieker.monitoring.writer.amqp

Class ChunkingAmqpWriter

java.lang.Object
kieker.monitoring.writer.amqp.ChunkingAmqpWriter
All Implemented Interfaces:
IRawDataWriter
public class ChunkingAmqpWriter
extends java.lang.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 java.lang.String CONFIG_EXCHANGENAME
    The name of the configuration property for the AMQP exchange name.
    static java.lang.String CONFIG_HEARTBEAT
    The name of the configuration property for the heartbeat timeout.
    static java.lang.String CONFIG_QUEUENAME
    The name of the configuration property for the AMQP queue name.
    static java.lang.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​(java.nio.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 java.lang.String CONFIG_URI
      The name of the configuration property for the server URI.

    • CONFIG_EXCHANGENAME

      public static final java.lang.String CONFIG_EXCHANGENAME
      The name of the configuration property for the AMQP exchange name.

    • CONFIG_QUEUENAME

      public static final java.lang.String CONFIG_QUEUENAME
      The name of the configuration property for the AMQP queue name.

    • CONFIG_HEARTBEAT

      public static final java.lang.String CONFIG_HEARTBEAT
      The name of the configuration property for the heartbeat timeout.

  • Constructor Details

    • ChunkingAmqpWriter

      public ChunkingAmqpWriter​(Configuration configuration) throws java.security.KeyManagementException, java.security.NoSuchAlgorithmException, java.net.URISyntaxException, java.io.IOException, java.util.concurrent.TimeoutException
      Throws:
      java.security.KeyManagementException
      java.security.NoSuchAlgorithmException
      java.net.URISyntaxException
      java.io.IOException
      java.util.concurrent.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​(java.nio.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