Package io.micronaut.nats.jetstream.annotation

Annotation Interface PushConsumer

@Documented @Retention(RUNTIME) @Target({METHOD,PARAMETER,TYPE}) @Bindable @Executable @MessageMapping @Inherited public @interface PushConsumer
Used to specify which stream should be used for messages.
Since:
4.0.0
Author:
Joachim Grimm

  • Element Details

    • value

      @AliasFor(annotation=io.micronaut.messaging.annotation.MessageMapping.class, member="value") String value
      Returns:
      The subject to subscribe to.
      Default:
      ""

    • connection

      @AliasFor(annotation=NatsConnection.class, member="connection") String connection
      Returns:
      The connection to use
      See Also:
      Default:
      ""

    • subject

      @AliasFor(annotation=Subject.class, member="value") String subject
      Default:
      ""

    • durable

      String durable
      Returns:
      the durable name
      See Also:
      • ConsumerConfiguration.Builder.durable(String)
      Default:
      ""

    • deliverPolicy

      io.nats.client.api.DeliverPolicy deliverPolicy
      Returns:
      the deliver policy
      See Also:
      • ConsumerConfiguration.Builder.deliverPolicy(DeliverPolicy)
      Default:
      All

    • startSequence

      long startSequence
      Returns:
      the start sequence
      See Also:
      • ConsumerConfiguration.Builder.startSequence(Long)
      Default:
      -9223372036854775808L

    • deliverSubject

      String deliverSubject
      Returns:
      the deliver subject
      See Also:
      • ConsumerConfiguration.Builder.deliverSubject(String)
      Default:
      ""

    • ackPolicy

      io.nats.client.api.AckPolicy ackPolicy
      Returns:
      the acknowledgment policy
      See Also:
      • ConsumerConfiguration.Builder.ackPolicy(AckPolicy)
      Default:
      Explicit

    • ackWait

      long ackWait
      Returns:
      the acknowledgment wait time in millis
      See Also:
      • ConsumerConfiguration.Builder.ackWait(long)
      Default:
      -9223372036854775808L

    • replayPolicy

      io.nats.client.api.ReplayPolicy replayPolicy
      Returns:
      the replay policy
      See Also:
      • ConsumerConfiguration.Builder.replayPolicy(ReplayPolicy)
      Default:
      Instant

    • maxDeliver

      long maxDeliver
      Returns:
      the max deliver
      See Also:
      • ConsumerConfiguration.Builder.maxDeliver(long)
      Default:
      -9223372036854775808L

    • filterSubject

      String filterSubject
      Returns:
      the filter subject
      See Also:
      • ConsumerConfiguration.Builder.filterSubject(String)
      Default:
      ""

    • rateLimit

      long rateLimit
      Returns:
      the rate limit
      See Also:
      • ConsumerConfiguration.Builder.rateLimit(long)
      Default:
      -9223372036854775808L

    • sampleFrequency

      String sampleFrequency
      Returns:
      the sample frequency
      See Also:
      • ConsumerConfiguration.Builder.sampleFrequency(String)
      Default:
      ""

    • idleHeartbeat

      long idleHeartbeat
      Returns:
      the idle heartbeat in millis
      See Also:
      • ConsumerConfiguration.Builder.idleHeartbeat(long)
      Default:
      -9223372036854775808L

    • flowControl

      long flowControl
      Returns:
      the flow control in millis
      See Also:
      • ConsumerConfiguration.Builder.flowControl(long)
      Default:
      -9223372036854775808L

    • backoff

      long[] backoff
      Returns:
      the back off in millis
      See Also:
      • ConsumerConfiguration.Builder.backoff(long...)
      Default:
      {-9223372036854775808L}

    • headersOnly

      boolean headersOnly
      Returns:
      the header only
      See Also:
      • ConsumerConfiguration.Builder.headersOnly(Boolean)
      Default:
      false

    • maxAckPending

      long maxAckPending
      Returns:
      the max acknowledgment pending
      See Also:
      • ConsumerConfiguration.Builder.maxAckPending(long)
      Default:
      -9223372036854775808L

    • deliverGroup

      String deliverGroup
      Returns:
      the deliver group
      See Also:
      • ConsumerConfiguration.Builder.deliverGroup(String)
      Default:
      ""

    • description

      String description
      Returns:
      the description
      See Also:
      • ConsumerConfiguration.Builder.description(String)
      Default:
      ""

    • queue

      String queue
      Returns:
      the queue of the consumer
      Default:
      ""

    • ordered

      boolean ordered
      Returns:
      flag indicating whether this subscription should be ordered
      See Also:
      • PushSubscribeOptions.Builder.ordered(boolean)
      Default:
      false