From 4cb49f9ee4b855f651605203b30cd04d37859c7f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 13 Nov 2017 16:48:04 -0500 Subject: [PATCH] Fix failing integ test Fix a test that was failing from an unrelated change made around content type in the message header --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index 088c9894e..32c73b1d7 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -2156,10 +2156,10 @@ public class KafkaBinderTests extends moduleOutputChannel.send(message); CountDownLatch latch = new CountDownLatch(1); - AtomicReference> inboundMessageRef = new AtomicReference<>(); + AtomicReference> inboundMessageRef = new AtomicReference<>(); moduleInputChannel.subscribe(message1 -> { try { - inboundMessageRef.set((Message) message1); + inboundMessageRef.set((Message) message1); } finally { latch.countDown(); @@ -2168,7 +2168,7 @@ public class KafkaBinderTests extends Assert.isTrue(latch.await(5, TimeUnit.SECONDS), "Failed to receive message"); assertThat(inboundMessageRef.get()).isNotNull(); - assertThat(new String(inboundMessageRef.get().getPayload(), StandardCharsets.UTF_8)).isEqualTo("testSendAndReceiveWithRawMode"); + assertThat(inboundMessageRef.get().getPayload()).isEqualTo("testSendAndReceiveWithRawMode"); producerBinding.unbind(); consumerBinding.unbind(); }