Added code to prevent 'live locks' when number of duplicates exceeds number of received messages without ack from RabbitMQ; added TODO.
More aggressive disruptor shutdown.