this.writerRegistry.register(recordClassName);
recordBuffer.putInt(this.writerRegistry.getId(recordClassName));
recordBuffer.putLong(monitoringRecord.getLoggingTimestamp());
monitoringRecord.writeBytes(recordBuffer, this.writeBytesAdapter);
if (this.flush) {
<BUG>WriterUtil.flushBuffer(recordBuffer, channel, LOG);
}</BUG>
}
@Override
public void onNewRegistryEntry(final String recordClassName, final int id) {

this.writerRegistry.register(recordClassName);
recordBuffer.putInt(this.writerRegistry.getId(recordClassName));
recordBuffer.putLong(monitoringRecord.getLoggingTimestamp());
monitoringRecord.writeBytes(recordBuffer, this.writeBytesAdapter);
if (this.flush) {
channel.flush(recordBuffer, LOG);
}
}
@Override
public void onNewRegistryEntry(final String recordClassName, final int id) {
