diff --git a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java index 60ccb91..20770a1 100644 --- a/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java +++ b/lib/src/main/java/ua/naiksoftware/stomp/dto/StompMessage.java @@ -86,7 +86,9 @@ public static StompMessage from(@Nullable String data) { headers.add(new StompHeader(matcher.group(1), matcher.group(2))); } - reader.skip("\n\n"); + if (reader.hasNext("\n\n")) { + reader.skip("\n\n") + } reader.useDelimiter(TERMINATE_MESSAGE_SYMBOL); String payload = reader.hasNext() ? reader.next() : null;