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

Interface AmqpCommonConfig

All Known Implementing Classes:
AmqpFragment, AmqpSourceConfig
public interface AmqpCommonConfig
The methods that must be implemented by both source and sink.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.qpid.protonj2.client.Client
    getClient()
    Creates a AMQP client.
    org.apache.qpid.protonj2.client.Connection
    getConnection(org.apache.qpid.protonj2.client.Client client)
    Creates a new Connection to an AMQP client.
    default org.apache.qpid.protonj2.client.Receiver
    getReceiver()
    Creates a new AMQP Receiver by creating and using a Client and Connection.
    org.apache.qpid.protonj2.client.Receiver
    getReceiver(org.apache.qpid.protonj2.client.Connection connection)
    Creates a new AMQP Receiver.

  • Method Details

    • getClient

      org.apache.qpid.protonj2.client.Client getClient()
      Creates a AMQP client. Must be closed when finished.
      Returns:
      a newly constructed client.

    • getConnection

      org.apache.qpid.protonj2.client.Connection getConnection(org.apache.qpid.protonj2.client.Client client) throws org.apache.qpid.protonj2.client.exceptions.ClientException
      Creates a new Connection to an AMQP client.
      Parameters:
      client - the client to connect to.
      Returns:
      the Connection. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP connection can not be established.

    • getReceiver

      org.apache.qpid.protonj2.client.Receiver getReceiver(org.apache.qpid.protonj2.client.Connection connection) throws org.apache.qpid.protonj2.client.exceptions.ClientException, ExecutionException, InterruptedException
      Creates a new AMQP Receiver.
      Parameters:
      connection - the AMQP connection to use for the receiver.
      Returns:
      the new AMQP Receiver. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP receiver can not be created.
      ExecutionException - If the receiver could not be created.
      InterruptedException - If the remote server was interrupted.

    • getReceiver

      default org.apache.qpid.protonj2.client.Receiver getReceiver() throws org.apache.qpid.protonj2.client.exceptions.ClientException, ExecutionException, InterruptedException
      Creates a new AMQP Receiver by creating and using a Client and Connection.
      Returns:
      the new AMQP Receiver. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP receiver can not be created.
      ExecutionException - If the receiver could not be created.
      InterruptedException - If the remote server was interrupted.