Windows 2008 x86_64 EC2 build

Build: #357 failed

Job: Default Job failed

Stages & jobs

  1. Default Stage

Code commits

Git

  • Gary Russell

    Gary Russell 52a7c23cbd9cb75962c3f4df3bf1ca3f7af7f626

    XD-3734: Rabbit: Fix Partitions with AutoDLQ
    JIRA: https://jira.spring.io/browse/XD-3734

    Partitioned streams have a single DLQ for each pipe, the originating partition
    is available in the `partition` message header.

    There were two issues with the implementation:

    1. The DLQ was bound to the DLX with the base queue name (no partitions) so rejected
    messages were not routed to the DLQ.
    2. On the producer side, the queue was bound with different (no) dlq arguments causing
    the declaration to fail; the bus should call `declareQueueIfNotPresent`.

    Add a test to reproduce the issues and fix the bus.

    • spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/rabbit/RabbitMessageBusTests.java (version 52a7c23cbd9cb75962c3f4df3bf1ca3f7af7f626)
    • spring-xd-messagebus-rabbit/src/main/java/org/springframework/xd/dirt/integration/rabbit/RabbitMessageBus.java (version 52a7c23cbd9cb75962c3f4df3bf1ca3f7af7f626)