Fixes amqp tests, particulary with lapinStream/replyTo completion lifecycle race