From 6f263291a6e57b42e121d16f25319c01c768b8fe Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Wed, 18 Dec 2019 14:16:37 -0500 Subject: [PATCH] Fix ToUpperCaseProcessorTests for CT header --- .../stream/testing/processor/ToUpperCaseProcessorTests.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/testing-samples/testing-demo/src/test/java/org/springframework/cloud/stream/testing/processor/ToUpperCaseProcessorTests.java b/testing-samples/testing-demo/src/test/java/org/springframework/cloud/stream/testing/processor/ToUpperCaseProcessorTests.java index b9245ba..3daa4d4 100644 --- a/testing-samples/testing-demo/src/test/java/org/springframework/cloud/stream/testing/processor/ToUpperCaseProcessorTests.java +++ b/testing-samples/testing-demo/src/test/java/org/springframework/cloud/stream/testing/processor/ToUpperCaseProcessorTests.java @@ -38,11 +38,14 @@ import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration; import org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.cloud.stream.test.binder.MessageCollector; +import org.springframework.http.MediaType; import org.springframework.integration.support.MessageBuilder; import org.springframework.messaging.Message; import org.springframework.messaging.MessageChannel; +import org.springframework.messaging.MessageHeaders; import org.springframework.messaging.support.GenericMessage; import org.springframework.test.annotation.DirtiesContext; +import org.springframework.util.MimeType; /** * The Spring Boot-base test-case to demonstrate how can we test Spring Cloud Stream applications @@ -97,6 +100,7 @@ class ToUpperCaseProcessorTests { Message expected = MessageBuilder.withPayload("HEADERS") .copyHeaders(testMessage.getHeaders()) + .setHeader(MessageHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON) .build(); Matcher> sameExceptIgnorableHeaders =