Implements Kata-RX-Consensus with BlockingQueue