sendHeartbeat(unifiedClientStats);
int ecnt = curState.getDataEventsBuffer().readEvents(cpRbc);
if (ecnt <= 0) {
_log.error("Not enough spece in the event buffer to add a control message :" + message);
boolean interrupted = !timer.backoffAndSleep();
if (interrupted)
throw new InterruptedException(
"Got interrupted while waiting to write control Message to EVB : " + message);
} else {