Package io.micronaut.rabbitmq.annotation

Annotation Interface Queue

@Documented @Retention(RUNTIME) @Target(METHOD) @Executable @Inherited public @interface Queue
Used to specify which queue messages should be consumed from. The queue must already exist in the broker.
Since:
1.1.0
Author:
James Kleeh

  • Element Details

    • value

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

    • reQueue

      boolean reQueue
      Only applies to consumer methods that do not inject an Acknowledgement instance.
      Returns:
      Whether nacks should re-queue the message.
      Default:
      false

    • exclusive

      boolean exclusive
      Returns:
      Whether the consumer is exclusive to the queue
      Default:
      false

    • autoAcknowledgment

      boolean autoAcknowledgment
      Returns:
      Whether the consumer should consider messages acknowledged once delivered
      Since:
      3.4.0
      Default:
      false

    • prefetch

      int prefetch
      Returns:
      The unacknowledged message limit
      Default:
      0

    • numberOfConsumers

      String numberOfConsumers
      Returns:
      The number of consumers used to consume from a queue concurrently
      Default:
      "1"

    • numberOfConsumersValue

      @AliasFor(member="numberOfConsumers") String numberOfConsumersValue
      Returns:
      The number of consumers used to consumer from a queue concurrently. Allows for the configuration property placeholders.
      Since:
      3.4.0
      Default:
      "1"

    • connection

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

    • executor

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