Add a RabbitMQ crash source and the finished_func feature necessary to allow ACKs to be sent after crashes are processed.