From 7b9c66c4ace391d067e7bd641a0880b68daca968 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 14 Jun 2022 10:49:16 -0400 Subject: [PATCH] Adjust KafkaBinder DLQ test error messages --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index 5db4c93a2..fe8151a1d 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -802,7 +802,7 @@ public class KafkaBinderTests extends .isEqualTo("foo.bar".getBytes(StandardCharsets.UTF_8)); assertThat(new String((byte[]) receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_MESSAGE))).startsWith( - "Dispatcher failed to deliver Message; nested exception is java.lang.RuntimeException: fail"); + "Dispatcher failed to deliver Message"); assertThat(receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_STACKTRACE)).isNotNull(); binderBindUnbindLatency(); @@ -1150,8 +1150,7 @@ public class KafkaBinderTests extends assertThat(((String) receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_MESSAGE))).startsWith( - "Dispatcher failed to deliver Message; nested exception " - + "is java.lang.RuntimeException: fail"); + "Dispatcher failed to deliver Message"); assertThat(receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_STACKTRACE)).isNotNull(); assertThat(receivedMessage.getHeaders() @@ -1186,16 +1185,11 @@ public class KafkaBinderTests extends assertThat(new String((byte[]) receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_MESSAGE))).startsWith( "Transaction rollback limit exceeded"); - assertThat(new String((byte[]) receivedMessage.getHeaders() - .get(KafkaMessageChannelBinder.X_EXCEPTION_MESSAGE))).contains( - "Dispatcher failed to deliver Message; nested exception " - + "is java.lang.RuntimeException: fail"); } else { assertThat(new String((byte[]) receivedMessage.getHeaders() .get(KafkaMessageChannelBinder.X_EXCEPTION_MESSAGE))).startsWith( - "Dispatcher failed to deliver Message; nested exception " - + "is java.lang.RuntimeException: fail"); + "Dispatcher failed to deliver Message"); } assertThat(receivedMessage.getHeaders()