A layer on top of poseidon-cluster for consuming messages generated by emque-producing