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