Add reconnect logic for queues