Skip to content

Commit 248c01c

Browse files
authored
Merge pull request #97 from bosch-io/bugfix/message-order
Fix reordering of messages
2 parents a2aecbc + a211124 commit 248c01c

File tree

1 file changed

+5
-10
lines changed

1 file changed

+5
-10
lines changed

java/src/main/java/org/eclipse/ditto/client/messaging/internal/WebSocketMessagingProvider.java

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -396,20 +396,15 @@ private WebSocket recreateWebSocket() {
396396

397397
@Override
398398
public void onBinaryMessage(final WebSocket websocket, final byte[] binary) {
399-
callbackExecutor.execute(() -> {
400-
final String stringMessage = new String(binary, StandardCharsets.UTF_8);
401-
LOGGER.debug(
402-
"Client <{}>: Received WebSocket byte array message <{}>, as string <{}> - don't know what to do" +
403-
" with it!.", sessionId, binary, stringMessage);
404-
});
399+
final String stringMessage = new String(binary, StandardCharsets.UTF_8);
400+
LOGGER.debug("Client <{}>: Received WebSocket byte array message <{}>, as string <{}> - don't know what to do" +
401+
" with it!.", sessionId, binary, stringMessage);
405402
}
406403

407404
@Override
408405
public void onTextMessage(final WebSocket websocket, final String text) {
409-
callbackExecutor.execute(() -> {
410-
LOGGER.debug("Client <{}>: Received WebSocket string message <{}>", sessionId, text);
411-
handleIncomingMessage(text);
412-
});
406+
LOGGER.debug("Client <{}>: Received WebSocket string message <{}>", sessionId, text);
407+
handleIncomingMessage(text);
413408
}
414409

415410
private void handleIncomingMessage(final String message) {

0 commit comments

Comments
 (0)