From ef0d9f51d8fd7c08246400056c19bdb8b49cafc2 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 5 Nov 2020 16:06:24 -0500 Subject: [PATCH] Fix websocket sink tests --- .../cloud/stream/app/websocket/sink/WebsocketSinkTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/applications/sink/websocket-sink/src/test/java/org/springframework/cloud/stream/app/websocket/sink/WebsocketSinkTests.java b/applications/sink/websocket-sink/src/test/java/org/springframework/cloud/stream/app/websocket/sink/WebsocketSinkTests.java index 4c8f47f0..58b8da82 100644 --- a/applications/sink/websocket-sink/src/test/java/org/springframework/cloud/stream/app/websocket/sink/WebsocketSinkTests.java +++ b/applications/sink/websocket-sink/src/test/java/org/springframework/cloud/stream/app/websocket/sink/WebsocketSinkTests.java @@ -87,7 +87,7 @@ public class WebsocketSinkTests { for (int i = 0; i < messageCount; i++) { String message = "message_" + i; messagesToSend.add(message); - inputDestination.send(MessageBuilder.withPayload(message.getBytes()).build()); + inputDestination.send(MessageBuilder.withPayload(message).build()); } return messagesToSend; }