PyRQ.Core.QueueWriter.QueueWriter.QueueWriter.put

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

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

                             quiet=quiet)
        iface.start()
        iface.put(DEBUG_SOMETHING())
        iface.close()
    def _onClear(self):

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

        details = qs.details()
        if not quiet: sys.stderr.write("BootQueueServer::load...[1.2]: %(D)s\r\n"%{"D":details})
        qw.put(details)
        if not quiet: sys.stderr.write("BootQueueServer::load...[1.2]\r\n")
    #    Now we have a queue which we can use to receive messages on:    'target'.

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

                        m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
                        qw = QueueWriter(target=replyTo, autoConnect=True, marshaller=m)
                        qw.put(Ping(data=data.data()))
        except Exception, _e:
            sys.stderr.write("Pinger got error: %(D)s...\r\n"%{"D":traceback.format_exc()})