Fix websocket sink tests

2020-11-05 16:06:24 -05:00
parent 7f37dc2bc5
commit ef0d9f51d8
1 changed files with 1 additions and 1 deletions
--- 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;
 	}