handle null in logReader and RollRecovery, add active field in Connection; abort sending message when Connection is not active
stage need to be marked as PENDING when collectorNode fail and no other collectorNode available; connectionMap need to be updated when stream reconnected