Package eu.vstoyanov.natsy.jetstream.model

Enum AckPolicy

  • All Implemented Interfaces:
    java.io.Serializable , kotlin.Comparable 
    
public enum AckPolicy
extends Enum<AckPolicy>

    Acknowledgment policy for consumers

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Constructor Summary

      Constructors 
      Constructor Description

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
      EXPLICIT

      Require explicit acknowledgment of each message

      "Each message must be acknowledged individually" (jnats io/nats/client/api/AckPolicy.java:34), so a run of processed messages is only acknowledged once every one of them is - which is what eu.vstoyanov.natsy.jetstream.JetStreamBatch.ackUpTo does under this policy.
      ALL

      Acknowledging one message also acknowledges every message below it

      "All messages with a sequence number less than the message acked are also acknowledged" (jnats io/nats/client/api/AckPolicy.java:30).
      NONE

      No acknowledgment required (fire-and-forget)

    • Method Summary

      Modifier and Type Method Description
      final Array<AckPolicy> values() Returns an array containing the constants of this enum type, in the order they're declared.
      final AckPolicy valueOf(String value) Returns the enum constant of this type with the specified name.
      final EnumEntries<AckPolicy> getEntries()

      • Methods inherited from class kotlin.Enum

        getName, getOrdinal

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

    • Method Detail

      • values

         final Array<AckPolicy> values()

        Returns an array containing the constants of this enum type, in the order they're declared.

        This method may be used to iterate over the constants.

      • valueOf

         final AckPolicy valueOf(String value)

        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)