From 85663ebea73924dbb0fa4ecd286447c23d464ccf Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 16 Apr 2020 11:47:01 -0400 Subject: [PATCH] Different topic names in test for DLQ. Unignore the test that was ignored previously. --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index 69977a1ea..62e64f2cc 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -867,7 +867,6 @@ public class KafkaBinderTests extends // For more details on the context of this test: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/657 @Test @SuppressWarnings("unchecked") - @Ignore public void testDlqWithProducerPropertiesSetAtBinderLevel() throws Exception { @@ -897,9 +896,9 @@ public class KafkaBinderTests extends DirectChannel moduleInputChannel = createBindableChannel("input", createConsumerBindingProperties(consumerProperties)); - Binding producerBinding = binder.bindProducer("foo.bar", + Binding producerBinding = binder.bindProducer("foo.bar-x", moduleOutputChannel, outputBindingProperties.getProducer()); - Binding consumerBinding = binder.bindConsumer("foo.bar", + Binding consumerBinding = binder.bindConsumer("foo.bar-x", "tdwcapsabl", moduleInputChannel, consumerProperties); // Let the consumer actually bind to the producer before sending a msg @@ -914,7 +913,7 @@ public class KafkaBinderTests extends dlqConsumerProperties.setMaxAttempts(1); Binding dlqConsumerBinding = binder.bindConsumer( - "error.foo.bar." + "tdwcapsabl", null, dlqChannel, + "error.foo.bar-x." + "tdwcapsabl", null, dlqChannel, dlqConsumerProperties); binderBindUnbindLatency();