Package org.opennms.netmgt.telemetry.config.api

Interface QueueDefinition

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.util.Optional<java.lang.Integer> getBatchIntervalMs()
      Messages are aggregated in batches before being dispatched.
      java.util.Optional<java.lang.Integer> getBatchSize()
      Messages are aggregated in batches before being dispatched.
      java.lang.String getName()
      The name of the protocol.
      java.util.Optional<java.lang.Integer> getNumThreads()
      Number of threads used for consuming/dispatching messages.
      java.util.Optional<java.lang.Integer> getQueueSize()
      Maximum number of messages to keep in memory while waiting to be dispatched.
      java.util.Optional<java.lang.Boolean> getUseRoutingKey()
      Whether or not the routing key should be used when forwarding messages to the broker.

    • Method Detail

      • getName

        java.lang.String getName()
        The name of the protocol. This is used as a suffix for any associated queues that are created and must be the same on both OpenNMS and Minion.
        Returns:
        the protocol name

      • getNumThreads

        java.util.Optional<java.lang.Integer> getNumThreads()
        Number of threads used for consuming/dispatching messages.
        Returns:
        the number of threads

      • getBatchSize

        java.util.Optional<java.lang.Integer> getBatchSize()
        Messages are aggregated in batches before being dispatched. When the batch reaches this size, it will be dispatched.
        Returns:
        the batch size

      • getBatchIntervalMs

        java.util.Optional<java.lang.Integer> getBatchIntervalMs()
        Messages are aggregated in batches before being dispatched. When the batch has been created for longer than this interval (ms) it will be dispatched, regardless of the current size.
        Returns:
        the batch interval

      • getQueueSize

        java.util.Optional<java.lang.Integer> getQueueSize()
        Maximum number of messages to keep in memory while waiting to be dispatched.
        Returns:
        the queue size

      • getUseRoutingKey

        java.util.Optional<java.lang.Boolean> getUseRoutingKey()
        Whether or not the routing key should be used when forwarding messages to the broker.
        Returns:
        whether or not to use the routing key