added reconnect feature incase queue restarts