Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(4)  |  Call(2)  |  Derive(0)  |  Import(2)

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
import sys
                        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()})

src/p/y/PyRQ-0.4.1/test/QueueServer/TestQueueServer.py   PyRQ(Download)
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
import unittest
    def testSimpleSendPingRoundtrip(self):
        details = self.rqs.details()
        eResult = Ping(replyTo=details, data={"hello.world!":{123:456}}, quiet=self.quiet)
        self.qw.put(eResult)
        received = self.target.get(True, timeout=self.TIMEOUT)