It's theoretically possible that calling topic.flush() would pull a reference to an ordered queue that would emit 'drain' (and thus be deleted) after the topic.flush() starts. This could result in calling queue.publish() and a reference error.