The while loops in the execute() methods of MongoPrimary would keep running if the connector is shut down and they don't complete normally, e.g. due to a connectivity issue.