fix: handle reconnection logic for zero queue consumer

fix: handle reconnection logic for zero queue consumer #800