PyRQ.Core.Marshal.MarshallerFactory.MarshallerFactory.get

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

            @staticmethod
    def get(name, **kwargs):
        if name==MarshallerFactory.DEFAULT:
            return DefaultMarshaller(name, **kwargs)
        raise UnknownMarshallerError(name)

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py PyRQ(Download)

        self.keepAlive(keepAlive)
        self._maxDataSize = maxDataSize
        self._marshaller = MarshallerFactory.get(marshaller, quiet=self._quiet, maxsize=self._maxDataSize)
        self._sockTimeout = sockTimeout
        self._sock = None

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/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)

    qs = QueueServer(host=options.host,
                     port=options.port,
                     marshaller=MarshallerFactory.get(mt, quiet=quiet),
                     target=target,
                     handlerClazz=handlerClazz,

#        pydevd.settrace(stdoutToServer = True, stderrToServer = True)
        qw = QueueWriter(target=QueueServerDetails(options.ackHost, options.ackPort),
                        marshaller=MarshallerFactory.get(mt, quiet=quiet),
                        autoConnect=True,
                        sockTimeout=10,

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

    def getMarshaller(self):
        return MarshallerFactory.get(self._marshallerType, quiet=self._quiet)
    def readTimeout(self, readTimeout):
        self._readTimeout = readTimeout
    def getReadTimeout(self):

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/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/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()

1 | 2 Next