Class PipeSourceParametersRabbitmqBrokerParameters


  • public final class PipeSourceParametersRabbitmqBrokerParameters
    extends java.lang.Object
    • Method Detail

      • batchSize

        public java.util.Optional<java.lang.Integer> batchSize()
        Returns:
        Maximum number of records to include in each batch. Maximum value of 10000.
      • maximumBatchingWindowInSeconds

        public java.util.Optional<java.lang.Integer> maximumBatchingWindowInSeconds()
        Returns:
        Maximum length of a time to wait for events. Maximum value of 300.
      • queueName

        public java.lang.String queueName()
        Returns:
        Name of the destination queue to consume. Maximum length of 1000.
      • virtualHost

        public java.util.Optional<java.lang.String> virtualHost()
        Returns:
        Name of the virtual host associated with the source broker. Maximum length of 200.