@Override
    public void add(RaftMessage message) {
        messages.offer(message);
    }
Mocked implementation which does not block in {@link #poll(long)}..
raft/src/test/java/org/apache/kafka/raft/MockMessageQueue.java