Package io.aiven.kafka.connect.amqp.common.config

Enum Class AmqpHeaderProperties

java.lang.Object
java.lang.Enum<AmqpHeaderProperties>
io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties
All Implemented Interfaces:
Serializable, Comparable<AmqpHeaderProperties>, Constable
public enum AmqpHeaderProperties extends Enum<AmqpHeaderProperties>
The properties found in the message object that are not otherwise handled with maps.

  • Nested Class Summary

    Nested classes/interfaces inherited from class java.lang.Enum

    Enum.EnumDesc<E extends Enum<E>>

  • Enum Constant Summary

    Enum Constants
    Enum Constant
    Description
    ABSOLUTE_EXPIRY
    the configured absolute time of expiration for this message
    CONTENT_ENCODING
    the assigned content encoding value for the message body section or null if not set
    CONTENT_TYPE
    the assigned content type value for the message body section or null if not set.
    CORRELATION_ID
    the currently assigned correlation ID or null if none set.
    CREATION_TIME
    the absolute time of creation for this message
    DELIVERY_COUNT
    the number of failed delivery attempts that this message has been part of
    DURABLE
    For an message being sent this method returns the current state of the durable flag on the message.
    FIRST_ACQUIRER
    if this message has been acquired by another link previously
    GROUP_ID
    the assigned group ID for this message or null if not set.
    GROUP_SEQUENCE
    the assigned group sequence for this message.
    MESSAGE_ID
    the currently set Message Id or null if none set.
    REPLY_TO
    the configured address of the node where replies to this message should be sent, or null if not set.
    REPLY_TO_GROUP_ID
    the client-specific id used so that client can send replies to this message to a specific group.
    SUBJECT
    the currently set subject metadata for this message or null if none set.
    TO
    the currently set 'To' address which indicates the intended destination of the message.
    USER_ID
    the currently set User ID or null if none set.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.connect.data.Schema
    getSchema()
    Gets the schema for this data item.
    String
    getSchemaName()
    Gets the schema name for this data item.
    static AmqpHeaderProperties
    valueOf(String name)
    Returns the enum constant of this class with the specified name.
    static AmqpHeaderProperties[]
    values()
    Returns an array containing the constants of this enum class, in the order they are declared.

    Methods inherited from class java.lang.Enum

    clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

    Methods inherited from class java.lang.Object

    getClass, notify, notifyAll, wait, wait, wait

  • Enum Constant Details

    • MESSAGE_ID

      public static final AmqpHeaderProperties MESSAGE_ID
      the currently set Message Id or null if none set.

    • USER_ID

      public static final AmqpHeaderProperties USER_ID
      the currently set User ID or null if none set.

    • TO

      public static final AmqpHeaderProperties TO
      the currently set 'To' address which indicates the intended destination of the message.

    • SUBJECT

      public static final AmqpHeaderProperties SUBJECT
      the currently set subject metadata for this message or null if none set.

    • REPLY_TO

      public static final AmqpHeaderProperties REPLY_TO
      the configured address of the node where replies to this message should be sent, or null if not set.

    • CORRELATION_ID

      public static final AmqpHeaderProperties CORRELATION_ID
      the currently assigned correlation ID or null if none set.

    • CONTENT_TYPE

      public static final AmqpHeaderProperties CONTENT_TYPE
      the assigned content type value for the message body section or null if not set.

    • CONTENT_ENCODING

      public static final AmqpHeaderProperties CONTENT_ENCODING
      the assigned content encoding value for the message body section or null if not set

    • ABSOLUTE_EXPIRY

      public static final AmqpHeaderProperties ABSOLUTE_EXPIRY
      the configured absolute time of expiration for this message

    • CREATION_TIME

      public static final AmqpHeaderProperties CREATION_TIME
      the absolute time of creation for this message

    • GROUP_ID

      public static final AmqpHeaderProperties GROUP_ID
      the assigned group ID for this message or null if not set.

    • GROUP_SEQUENCE

      public static final AmqpHeaderProperties GROUP_SEQUENCE
      the assigned group sequence for this message.

    • REPLY_TO_GROUP_ID

      public static final AmqpHeaderProperties REPLY_TO_GROUP_ID
      the client-specific id used so that client can send replies to this message to a specific group.

    • DURABLE

      public static final AmqpHeaderProperties DURABLE
      For an message being sent this method returns the current state of the durable flag on the message. For a received message this method returns the durable flag value at the time of sending (or false if not set) unless the value is updated after being received by the receiver

    • FIRST_ACQUIRER

      public static final AmqpHeaderProperties FIRST_ACQUIRER
      if this message has been acquired by another link previously

    • DELIVERY_COUNT

      public static final AmqpHeaderProperties DELIVERY_COUNT
      the number of failed delivery attempts that this message has been part of

  • Method Details

    • values

      public static AmqpHeaderProperties[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared

    • valueOf

      public static AmqpHeaderProperties valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null

    • getSchema

      public org.apache.kafka.connect.data.Schema getSchema()
      Gets the schema for this data item.
      Returns:
      the schema for this data item.

    • getSchemaName

      public String getSchemaName()
      Gets the schema name for this data item.
      Returns:
      the schema name for this data item.