} else {
<BUG>return ChannelBuffers.copiedBuffer(objectMapper.writeValueAsBytes(events));
}</BUG>
}
@Nullable
<BUG>private List<Map<String, Object>> processBuffer(Channel channel, ChannelBuffer channelBuffer) throws IOException {
</BUG>
channelBuffer.markReaderIndex();
@SuppressWarnings("unused")
byte version = channelBuffer.readByte();

} else {
return events;
}
}
@Nullable
private ChannelBuffer[] processBuffer(Channel channel, ChannelBuffer channelBuffer) throws IOException {
channelBuffer.markReaderIndex();
@SuppressWarnings("unused")
byte version = channelBuffer.readByte();
