elif command == "listener":
if len(args) != 0:
raise InvalidArguments()
- threaded_consumer(module.QUEUE_RESP, do_listen, threads=threads)
+ logging.getLogger().addHandler(printed)
+ threaded_consumer(module.QUEUE_RESP, None, do_listen, threads=threads)
elif command == "enqueue":
if len(args) != 0:
raise InvalidArguments()
- enqueue_all(queue, module.generate_tasks())
+ logging.getLogger().addHandler(printed)
+ enqueue_all(module.QUEUE, module.generate_tasks())
elif command == "debug":
if len(args) != 2:
raise InvalidArguments()