broke create_queue out so we can have a queue if we publish before the worker is started