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:
      ""