SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Different topic names in test for DLQ.

Browse Source 
Unignore the test that was ignored previously.
This commit is contained in:
Soby Chacko
2020-04-16 11:47:01 -04:00
parent c17752b02d
commit 85663ebea7
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

@@ -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<MessageChannel> producerBinding = binder.bindProducer("foo.bar",
Binding<MessageChannel> producerBinding = binder.bindProducer("foo.bar-x",
moduleOutputChannel, outputBindingProperties.getProducer());
Binding<MessageChannel> consumerBinding = binder.bindConsumer("foo.bar",
Binding<MessageChannel> 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<MessageChannel> dlqConsumerBinding = binder.bindConsumer(
"error.foo.bar." + "tdwcapsabl", null, dlqChannel,
"error.foo.bar-x." + "tdwcapsabl", null, dlqChannel,
dlqConsumerProperties);
binderBindUnbindLatency();