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

Class AmqpContext.AmqpContextBuilder

java.lang.Object
io.aiven.commons.kafka.connector.source.task.Context.Builder<AmqpContext.AmqpContextBuilder>
io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder
Enclosing class:
AmqpContext
public static class AmqpContext.AmqpContextBuilder extends io.aiven.commons.kafka.connector.source.task.Context.Builder<AmqpContext.AmqpContextBuilder>
The builder fro the AMQP Context.

  • Nested Class Summary

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

    io.aiven.commons.kafka.connector.source.task.Context.Builder.Validator

  • Constructor Summary

    Constructors
    Constructor
    Description
    AmqpContextBuilder(io.aiven.commons.kafka.connector.source.task.Context context)
    Construct the builder from a context.
    AmqpContextBuilder(Comparable<?> nativeKey, org.apache.qpid.protonj2.client.Delivery delivery)
    Construct a builder from a native key and a Delivery object.

  • Method Summary

    Modifier and Type
    Method
    Description
    AmqpContext
    build()
     
    AmqpContext.AmqpContextBuilder
    delivery(org.apache.qpid.protonj2.client.Delivery delivery)
    Set the delivery in the context.

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

    addValidator, nativeKey, offset, partition, self, set, topic, validate

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AmqpContextBuilder

      public AmqpContextBuilder(io.aiven.commons.kafka.connector.source.task.Context context)
      Construct the builder from a context.
      Parameters:
      context - the context to create the builder from.

    • AmqpContextBuilder

      public AmqpContextBuilder(Comparable<?> nativeKey, org.apache.qpid.protonj2.client.Delivery delivery)
      Construct a builder from a native key and a Delivery object.
      Parameters:
      nativeKey - the native key.
      delivery - the Delivery object.

  • Method Details

    • delivery

      public AmqpContext.AmqpContextBuilder delivery(org.apache.qpid.protonj2.client.Delivery delivery)
      Set the delivery in the context.
      Parameters:
      delivery - the delivery value for the context.
      Returns:
      this.

    • build

      public AmqpContext build()
      Specified by:
      build in class io.aiven.commons.kafka.connector.source.task.Context.Builder<AmqpContext.AmqpContextBuilder>