improved error handling for connection loss && implemented internal queue throttle