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/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQTab.py   PyRQ(Download)
        self.qs = QueueServer(host=self.debugger.host,
                              port=32323,
                              marshaller=MarshallerFactory.get(MarshallerFactory.DEFAULT),
                              target = self.q,
                              quiet=self.debugger.quiet)
    def staticConnect(debugger, target, msg=None):
        if target:
            #    Now try and connect to this PyRQ.
            iface = QueueWriter( target=target,
                                 marshaller=MarshallerFactory.get(MarshallerFactory.DEFAULT),

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RawQueueData.py   PyRQ(Download)
    def _onTest(self):
        quiet=self._parent.debugger.quiet
        iface = QueueWriter( target=self._parent.details,
                             autoConnect=True,
                             marshaller=MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=quiet),

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/Debugger/Sinks/ServerSink.py   PyRQ(Download)
        self._q = Queue()
        self.quiet= quiet
        self._marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=quiet)
        self._qw = QueueWriter(target=details, autoConnect=True, marshaller=self._marshaller, quiet=quiet)
        self._qw.start()

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/Debugger/RRQDebugger.py   PyRQ(Download)
    #    Start a dummyQueueServer:
    q = Queue()
    m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
    QS = QueueServer(port=22334, target=q, quiet=True, marshaller=m)
    QS.start()

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/SubprocessQueueServer.py   PyRQ(Download)
    def _createResources(cwd, timeout, quiet):
        #    Create our listener:
        target = Queue()
        marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=quiet)
        tQs = QueueServer(host="127.0.0.1", port=54000, target=target, marshaller=marshaller, quiet=quiet).start().waitUntilRunning()

src/p/y/PyRQ-0.4.1/Mock/Debugger/Sinks/ServerSink.py   PyRQ(Download)
        self._q = Queue()
        self.quiet= quiet
        self._marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=quiet)
        self._qw = QueueWriter(target=details, autoConnect=True, marshaller=self._marshaller, quiet=quiet)
        self._qw.start()

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/BootQueueServer.py   PyRQ(Download)
        "host to bind to. Default is '%(DHA)s'"%{"DHA":QueueServer.DEFAULT_HOST})
    parser.add_option("--%(H)s"%{"H":QueueServerOptions.MARSHALLER_TYPE}, action="store", dest="marshallerType", type="int", 
        metavar="MARSHALLER_TYPE", default=MarshallerFactory.DEFAULT, help="Type of the Queue's marshaller."
        "Default is '%(D)s'."%{"D":MarshallerFactory.DEFAULT})
    parser.add_option("--%(H)s"%{"H":QueueServerOptions.CLAZZPATH}, action="store", dest="clazzpath", type="str", 

src/p/y/PyRQ-0.4.1/Mock/Debugger/MockDebugger.py   PyRQ(Download)
    #    Start a dummyQueueServer:
    q = Queue()
    m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
    QS = QueueServer(port=22334, target=q, quiet=True, marshaller=m)
    QS.start()

src/p/y/PyRQ-0.4.1/Mock/Pinger.py   PyRQ(Download)
                        quiet = data.quiet()
                        if not quiet: sys.stderr.write("Pinger pinging data back to %(H)s:%(P)s\r\n"%{"H":host, "P":port})
                        m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
                        qw = QueueWriter(target=replyTo, autoConnect=True, marshaller=m)
                        qw.put(Ping(data=data.data()))

src/p/y/PyRQ-0.4.1/test/RRQReader/TestRRQReader.py   PyRQ(Download)
        self.iface = PyRQIface(quiet=self.quiet, ref="default", loggingModule=testLoggingModule)
        self.dummyQueue = Queue()
        self.marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=self.quiet)
        desiredPort = "19001"
        self.r = SubprocessQueueServer(
        self.dummyQueue = Queue()
        self.iface = PyRQIface(ref="test", quiet=self.quiet, loggingModule=testLoggingModule)
        self.marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=self.quiet)
        desiredPort = "19001"
        self.r = SubprocessQueueServer(

  1 | 2  Next