Fix leak when consumer failed to connect