add reconnect logic for queues