Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(0)  |  Call(0)  |  Derive(0)  |  Import(0)

src/t/x/tx0mq-HEAD/examples/zguide/chapter04/service-oriented-reliable-queuing/mdbroker.py   tx0mq(Download)
                self.worker_waiting(worker)
 
        elif (MDP.W_REPLY == command):
            if (worker_ready):
                # Remove & save client return envelope and insert the

src/t/x/tx0mq-HEAD/examples/zguide/chapter04/asynchronous-majordomo/mdbroker.py   tx0mq(Download)
                self.worker_waiting(worker)
 
        elif (MDP.W_REPLY == command):
            if (worker_ready):
                # Remove & save client return envelope and insert the

src/t/x/tx0mq-HEAD/examples/zguide/chapter04/service-oriented-reliable-queuing/mdwrkapi.py   tx0mq(Download)
            assert self.reply_to is not None
            reply = [self.reply_to, ''] + reply
            self.send_to_broker(MDP.W_REPLY, msg=reply)
 
        self.expect_reply = True

src/t/x/tx0mq-HEAD/examples/zguide/chapter04/asynchronous-majordomo/mdwrkapi.py   tx0mq(Download)
            assert self.reply_to is not None
            reply = [self.reply_to, ''] + reply
            self.send_to_broker(MDP.W_REPLY, msg=reply)
 
        self.expect_reply = True