PyRQ.Core.QueueWriter.QueueWriter.QueueWriter

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

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/BootQueueServer.py PyRQ(Download)

        #    Send the ack back!
        if not quiet: sys.stderr.write("BootQueueServer::load...[0.1]: %(H)s:%(P)s[1]\r\n"%{"H":options.ackHost, "P":options.ackPort})
        from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
#        import pydevd
#        pydevd.settrace(stdoutToServer = True, stderrToServer = True)
        qw = QueueWriter(target=QueueServerDetails(options.ackHost, options.ackPort),

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RawQueueData.py PyRQ(Download)

from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.Messages.DEBUG import DEBUG_SOMETHING, DEBUG_START
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
 
class RawQueueData(QtGui.QFrame):

    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/Mock/Debugger/Sinks/ServerSink.py PyRQ(Download)

from Mock.Debugger.iMockDebuggerSink import iMockDebuggerSink
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from Queue import Empty
from multiprocessing.queues import 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()
        self.thread = None

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQTab.py PyRQ(Download)

    DEBUG_QUERY
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from PyRQ.Iface.PyRQIface import PyRQIface
from PyRQ.RRQ.Debugger.iRRQDebuggerSink import iRRQDebuggerSink

    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/RRQ/Debugger/Sinks/ServerSink.py PyRQ(Download)

 
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from PyRQ.RRQ.Debugger.iRRQDebuggerSink import iRRQDebuggerSink
from Queue import Empty

        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()
        self.thread = None

src/p/y/PyRQ-0.4.1/Mock/Pinger.py PyRQ(Download)

 
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from PyRQ.RRQ.Messages.Ping import Ping
from Queue import Empty

                        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()))
        except Exception, _e:

src/p/y/PyRQ-0.4.1/test/QueueServer/TestQueueServer.py PyRQ(Download)

from PyRQ.Core.QueueServer.QueueServerHandler import QueueServerHandler
from PyRQ.Core.QueueServer.SubprocessQueueServer import SubprocessQueueServer
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from PyRQ.RRQ.Messages.Ping import Ping
from multiprocessing.queues import Queue

        self._createQueueServer()
        #    Create the QueueWriter:
        self.qw = QueueWriter(target=self.details,
                              quiet=self.quiet,
                              marshaller=self.m,