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

Fix StreamFunctionAdapterTests and StreamMessageOperatorsTests

Browse Source
This commit is contained in:
Jonatan Ivanov
2021-11-22 15:17:16 -08:00
parent eab9079e9b
commit b718d1130f
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
View File

@@ -63,7 +63,7 @@ public class StreamFunctionAdapterTests {
Message<byte[]> 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");

2
tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamMessageOperatorsTests.java
View File

@@ -68,7 +68,7 @@ public class StreamMessageOperatorsTests {
Message<byte[]> 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");