io.micronaut.rabbitmq.annotation

Annotation Type Queue

@Documented
 @Retention(value=RUNTIME)
 @Target(value=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

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
java.lang.String	value

Optional Element Summary

Optional Elements

Modifier and Type	Optional Element and Description
java.lang.String	connection
boolean	exclusive
java.lang.String	executor
int	numberOfConsumers
int	prefetch
boolean	reQueue Only applies to consumer methods that do not inject an Acknowledgement instance.

Element Detail

value

@AliasFor(annotation=io.micronaut.messaging.annotation.MessageMapping.class,
          member="value")
public abstract java.lang.String value

Returns:

The queue to subscribe to.

reQueue

public abstract 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

public abstract boolean exclusive

Returns:

Whether the consumer is exclusive to the queue

Default:

false

prefetch

public abstract int prefetch

Returns:

The unacknowledged message limit

Default:

0

numberOfConsumers

public abstract int numberOfConsumers

Returns:

The number of consumers used to consumer from a queue concurrently

Default:

1

connection

@AliasFor(annotation=RabbitConnection.class,
          member="connection")
public abstract java.lang.String connection

Returns:

The connection to use

See Also:

RabbitConnection.connection()

Default:

""

executor

@AliasFor(annotation=RabbitConnection.class,
          member="executor")
public abstract java.lang.String executor

Returns:

The executor to use

See Also:

RabbitConnection.executor()

Default:

""