From b718d1130fa8d8cd5e63ac87f34c5a36b41ff7aa Mon Sep 17 00:00:00 2001 From: Jonatan Ivanov Date: Mon, 22 Nov 2021 15:17:16 -0800 Subject: [PATCH] Fix StreamFunctionAdapterTests and StreamMessageOperatorsTests --- .../sleuth/instrument/messaging/StreamFunctionAdapterTests.java | 2 +- .../instrument/messaging/StreamMessageOperatorsTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java index 49fc64488..d76762724 100644 --- a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java +++ b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java @@ -63,7 +63,7 @@ public class StreamFunctionAdapterTests { Message message = this.outputDestination.receive(200L); assertThat(message).isNotNull(); - assertThat(message.getPayload()).isEqualTo("HELLO".getBytes()); + assertThat(message.getPayload()).isEqualTo("\"HELLO\"".getBytes()); String b3 = message.getHeaders().get("b3", String.class); assertThat(b3).startsWith("4883117762eb9420"); diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java index f3d8be101..1eb85f8a6 100644 --- a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java +++ b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java @@ -68,7 +68,7 @@ public class StreamMessageOperatorsTests { Message message = this.outputDestination.receive(200L); assertThat(message).isNotNull(); - assertThat(message.getPayload()).isEqualTo("HELLO".getBytes()); + assertThat(message.getPayload()).isEqualTo("\"HELLO\"".getBytes()); String b3 = message.getHeaders().get("b3", String.class); assertThat(b3).startsWith("4883117762eb9420");