"""
import logging
+from Queue import Queue, Empty
from .command import NullQueue
communication queues, so make sure they will not need user
interaction.
"""
+ log = logging.getLogger('hooke')
log.debug('engine running internal %s with %s'
% (command, arguments))
cmd = hooke.command_by_name[command]
- cmd.run(hooke, NullQueue(), NullQueue(), arguments)
+ outqueue = Queue()
+ cmd.run(hooke, NullQueue(), outqueue, **arguments)
+ while True:
+ try:
+ msg = outqueue.get(block=False)
+ except Empty:
+ break
+ log.debug('engine message from %s (%s): %s' % (command, type(msg), msg))