Package io.aiven.kafka.connect.amqp.source

Class AmqpContext

java.lang.Object
io.aiven.commons.kafka.connector.source.task.Context
io.aiven.kafka.connect.amqp.source.AmqpContext
public class AmqpContext extends io.aiven.commons.kafka.connector.source.task.Context
The context for the AMQP processes.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    AmqpContext.AmqpContextBuilder
    The builder fro the AMQP Context.

    Nested classes/interfaces inherited from class io.aiven.commons.kafka.connector.source.task.Context

    io.aiven.commons.kafka.connector.source.task.Context.Builder<T extends io.aiven.commons.kafka.connector.source.task.Context.Builder<T>>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    DELIVERY_KEY
    The key for the delivery property.

    Fields inherited from class io.aiven.commons.kafka.connector.source.task.Context

    NATIVE_KEY, OFFSET_KEY, PARTITION_KEY, TOPIC_KEY

  • Method Summary

    Modifier and Type
    Method
    Description
    AmqpContext.AmqpContextBuilder
    builder()
     
    org.apache.qpid.protonj2.client.Delivery
    getDelivery()
    Gets the Delivery

    Methods inherited from class io.aiven.commons.kafka.connector.source.task.Context

    builder, equals, getInteger, getLong, getNativeKey, getNumber, getObject, getObject, getOffset, getPartition, getShort, getString, getTopic, hashCode, toString

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Field Details

    • DELIVERY_KEY

      public static final String DELIVERY_KEY
      The key for the delivery property.

  • Method Details

    • getDelivery

      public org.apache.qpid.protonj2.client.Delivery getDelivery()
      Gets the Delivery
      Returns:
      the Delivery.

    • builder

      public AmqpContext.AmqpContextBuilder builder()
      Overrides:
      builder in class io.aiven.commons.kafka.connector.source.task.Context