in gemini/src/main/java/deltix/connector/crypto/gemini/GeminiWsClient.java [190:205]
public void onTextFrame(String payload, boolean finalFragment, int rsv) {
if (getLog().isTraceEnabled()) {
getLog().trace("WebSocket: %s").with(payload);
}
if (payload == null || payload.isEmpty()) {
return;
}
if (!finalFragment) {
getLog().warn("We got fragmented message but they are not supported");
}
try {
handleWsMessage(payload);
} catch (Exception e) {
getLog().error("Payload handling failure: %s %s").with(payload).with(e);
}
}