Skip to content

Commit 69f5e9c

Browse files
committed
Create durable RabbitMQ queues in tests
This makes our tests compatible with RabbitMQ 4.3
1 parent cf9a537 commit 69f5e9c

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

modules/flowable-event-registry-spring/src/test/java/org/flowable/eventregistry/spring/test/rabbit/RabbitChannelDefinitionProcessorTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -544,7 +544,7 @@ void eventWithMultipleHeaders() {
544544
void eventShouldBeSendAfterOutboundChannelDefinitionIsRegisteredWithDefinedExchange() {
545545
TopicExchange exchange = new TopicExchange("flowable-test");
546546
rabbitAdmin.declareExchange(exchange);
547-
Queue queue = new Queue("outbound-customer", false);
547+
Queue queue = new Queue("outbound-customer", true);
548548
rabbitAdmin.declareQueue(queue);
549549
Binding binding = BindingBuilder.bind(queue).to(exchange).with("customer");
550550
rabbitAdmin.declareBinding(binding);
@@ -857,7 +857,7 @@ void rabbitOutboundChannelShouldResolveRoutingKeyFromExpressionUsingCustomBean()
857857
void rabbitOutboundChannelShouldResolveExchangeFromExpression() {
858858
TopicExchange exchange = new TopicExchange("test-expression-customer");
859859
rabbitAdmin.declareExchange(exchange);
860-
Queue queue = new Queue("outbound-customer", false);
860+
Queue queue = new Queue("outbound-customer", true);
861861
rabbitAdmin.declareQueue(queue);
862862
queuesToDelete.add("outbound-customer");
863863
Binding binding = BindingBuilder.bind(queue).to(exchange).with("customer");

modules/flowable-event-registry-spring/src/test/java/org/flowable/eventregistry/spring/test/rabbit/RabbitChannelRebootEngineTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -206,12 +206,12 @@ public void destroy() throws Exception {
206206

207207
@Bean
208208
public Queue testListenerQueue() {
209-
return new Queue("testListener", false);
209+
return new Queue("testListener", true);
210210
}
211211

212212
@Bean
213213
public Queue testCustomerQueue() {
214-
return new Queue("test-customer", false);
214+
return new Queue("test-customer", true);
215215
}
216216

217217
@RabbitListener(queues = "testListener")

0 commit comments

Comments
 (0)