class PersistentMessageBuffer implements MessageBuffer {

    @Override
    public long append(long timestamp, String routingKey, byte[] payload) throws IOException {
        return append(timestamp, routingKey, Channels.newChannel(new ByteArrayInputStream(payload)), payload.length);
    }

    public  PersistentMessageBuffer(File dir);

}