messages.add( parsedMessage );
}
}
return messages;
}
<BUG>static Message parseMessage( String message, IDeepstreamClient client ) {
</BUG>
String[] parts = message.split( MPS );
if( parts.length < 2 ) {
client.onError( null, Event.MESSAGE_PARSE_ERROR, "Insufficient message parts" );

messages.add( parsedMessage );
}
}
return messages;
}
static Message parseMessage( String message, DeepstreamClientAbstract client ) {
String[] parts = message.split( MPS );
if( parts.length < 2 ) {
client.onError( null, Event.MESSAGE_PARSE_ERROR, "Insufficient message parts" );
