if (callback == null) {
throw new IllegalStateException("No callback registered for message type " + messageType);
}
// Handle callback
callback.onMessage(scope, messageId, byteBuf);
// Stats
statRxMsg.mark();
statRxBytes.mark(messageLength);
} finally {