diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java index 8113456fe..9d38e2a08 100644 --- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java +++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java @@ -19,7 +19,6 @@ package org.springframework.cloud.stream.binder.rabbit; import java.lang.reflect.Constructor; import java.nio.charset.StandardCharsets; import java.util.Arrays; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.CountDownLatch; @@ -993,14 +992,6 @@ public class RabbitBinderTests extends @Test public void testAutoBindDLQwithRepublish() throws Exception { - // pre-declare the queue with dead-lettering, users can also use a policy - RabbitAdmin admin = new RabbitAdmin(this.rabbitAvailableRule.getResource()); - Map args = new HashMap(); - args.put("x-dead-letter-exchange", TEST_PREFIX + "DLX"); - args.put("x-dead-letter-routing-key", TEST_PREFIX + "dlqpubtest.default"); - Queue queue = new Queue(TEST_PREFIX + "dlqpubtest.default", true, false, false, args); - admin.declareQueue(queue); - RabbitTestBinder binder = getBinder(); ExtendedConsumerProperties consumerProperties = createConsumerProperties(); consumerProperties.getExtension().setPrefix(TEST_PREFIX); diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java index 9c48ee44f..961ae418e 100644 --- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java +++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java @@ -19,6 +19,7 @@ package org.springframework.cloud.stream.binder.rabbit.integration; import java.util.ArrayList; import java.util.List; import java.util.Map; +import java.util.UUID; import org.junit.After; import org.junit.ClassRule; @@ -87,10 +88,8 @@ public class RabbitBinderModuleTests { context = null; } RabbitAdmin admin = new RabbitAdmin(rabbitTestSupport.getResource()); - admin.deleteQueue("binder.input.default"); - admin.deleteQueue("binder.output.default"); - admin.deleteExchange("binder.input"); - admin.deleteExchange("binder.output"); + admin.deleteExchange("input"); + admin.deleteExchange("output"); } @Test @@ -132,6 +131,7 @@ public class RabbitBinderModuleTests { ConnectionNameStrategy cns = TestUtils.getPropertyValue(cf, "connectionNameStrategy", ConnectionNameStrategy.class); assertThat(cns.obtainNewConnectionName(cf)).isEqualTo("foo#2"); + new RabbitAdmin(rabbitTestSupport.getResource()).deleteExchange("checkPF"); } @Test @@ -240,7 +240,8 @@ public class RabbitBinderModuleTests { .getPropertyValue("indicators"); assertThat(healthIndicators).containsKey("custom"); assertThat(healthIndicators.get("custom").health().getStatus()).isEqualTo(Status.UP); - Binding binding = binder.bindProducer("foo", new DirectChannel(), + String name = UUID.randomUUID().toString(); + Binding binding = binder.bindProducer(name, new DirectChannel(), new ExtendedProducerProperties<>(new RabbitProducerProperties())); RetryTemplate template = TestUtils.getPropertyValue(binding, "lifecycle.amqpTemplate.retryTemplate", RetryTemplate.class); @@ -253,6 +254,7 @@ public class RabbitBinderModuleTests { assertThat(backOff.getMultiplier()).isEqualTo(1.1); assertThat(backOff.getMaxInterval()).isEqualTo(3000L); binding.unbind(); + new RabbitAdmin(rabbitTestSupport.getResource()).deleteExchange(name); context.close(); }