'Sends a message to the handle_message method.
The message is read from the iterated queue.
@returns: True to gobject to keep calling it, and False when all
it\'s done.'

def _process_queue(self):

    while True:
        (yield True)
        try:
            msg = self.messages.get(timeout=0.01)
        except Queue.Empty:
            continue
        else:
            if (msg is None):
                continue
            for _ in self.handle_message(msg):
                (yield True)
