Build: #126 was successful Changes by Artem Bilan

Code commits

Plan Repository

  • Artem Bilan

    Artem Bilan e50cb897c7d6c895d5b4dbb2661e809440e66d04

    AMQP-801-2: Introduce ConsumerDecorator
    JIRA: https://jira.spring.io/browse/AMQP-801

    To properly assign the queue to the `ConsumeOkEvent`, we need perform
    such a logic in the `Consumer.handleConsumeOk()`.

    * Introduce `BlockingQueueConsumer.ConsumerDecorator` to be created on
    each `channel.basicConsume()` for wrapping the target `InternalConsumer`
    per queue
    * Add getters to the `ConsumeOkEvent` for better interoperability
    * Assert assigned queue names for the `ConsumeOkEvent`s in the
    `SimpleMessageListenerContainerIntegration2Tests`

    **Cherry-pick to 1.7.x**

    * Add `ConsumerDecorator.consumerTag` property
    * Add `ConsumerDecorator.toString()`
    * Add JavaDocs for the `ConsumeOkEvent`

    • spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainerIntegration2Tests.java (version e50cb897c7d6c895d5b4dbb2661e809440e66d04)
    • spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/ConsumeOkEvent.java (version e50cb897c7d6c895d5b4dbb2661e809440e66d04)
    • spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java (version e50cb897c7d6c895d5b4dbb2661e809440e66d04)