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

All Samples(34)  |  Call(28)  |  Derive(0)  |  Import(6)
@summary: A physical interface to a PyRQ.
The PyRQ must be reachable on the network or loopback adaptor.
To make all interfaces use the same PyRQ instance, set it's details: setGlobalPYRQ().
To make each interface use a different PyRQ instance, override it with: setPYRQ().

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQTab.py   PyRQ(Download)
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
from PyRQ.RRQ.RRQPackage import RRQPackage
    def getIface(self, namespace=None):
        return PyRQIface(namespace=namespace,
                         quiet=True,
                         PyRqDetails=self.details,
                         keepAlive=True,
                         )
    @staticmethod
    def staticGetIface(details, namespace=None):
        return PyRQIface(namespace=namespace,

src/p/y/PyRQ-0.4.1/test/RRQReader/TestRRQReader.py   PyRQ(Download)
from PyRQ.Core.Utils.ImportUtils import _importModuleName
from PyRQ.Core.Utils.PyRQTimeUtils import PyRQTimeUtils
from PyRQ.Iface.PyRQIface import PyRQIface
from Queue import Empty, Full
from multiprocessing.queues import Queue
        self._timers = []
        self.namespaces = []
        self.iface = PyRQIface(quiet=self.quiet, ref="default", loggingModule=testLoggingModule)
        self.dummyQueue = Queue()
        self.marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=self.quiet)
        def doGet(initialDelay, ref, getTimeout):
            time.sleep(initialDelay)
            self.logger.debug("GET %(R)s START"%{"R":ref})
            iface = PyRQIface(namespace=self.namespace, quiet=self.quiet, ref="get.%(R)s"%{"R":ref}, loggingModule=testLoggingModule)
            while self.timerTerminate==0:
        def doPut(initialDelay, ref, putTimeout, dataQ):
            time.sleep(initialDelay)
            self.logger.debug("PUT %(R)s START"%{"R":ref})
            iface = PyRQIface(namespace=self.namespace, quiet=self.quiet, ref="put.%(R)s"%{"R":ref}, loggingModule=testLoggingModule)
            while self.timerTerminate==0:
    def testNonBlockingGet(self):
        self.namespace = self._createInterface()
        iface = PyRQIface(ref="testNonBlockingGet", namespace=self.namespace, quiet=self.quiet, loggingModule=testLoggingModule)
        try:
            _data = iface.get(block=False, timeout=None)

src/p/y/PyRQ-0.4.1/test/RRQReader/TestQueueBlocking.py   PyRQ(Download)
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.SubprocessQueueServer import SubprocessQueueServer
from PyRQ.Iface.PyRQIface import PyRQIface
from Queue import Full, Empty
from multiprocessing.queues import Queue
        self._timers = []
        self.namespaces = []
        self.iface = PyRQIface(quiet=self.quiet, ref="test")
        self.dummyQueue = Queue()
        self.marshaller = MarshallerFactory.get(MarshallerFactory.DEFAULT, quiet=self.quiet)
    def _closeQueue(self, namespace, delay=0, name="Closer"):
        iface = PyRQIface(namespace=namespace, quiet=self.quiet, ref=name)
        def close(d):
            if delay!=None:
                time.sleep(delay)
        when the socket is remotely closed.
        """
        iface = PyRQIface(quiet=self.quiet, ref="creator-testDelayedGetWithTimeoutThenClosed")
        namespace = iface.create(maxsize=maxsize)
        self._closeQueue(namespace, delay=2, name="closer-testDelayedGetThenClosed")
        iface = PyRQIface(namespace=namespace, quiet=self.quiet, ref="testDelayedGetThenClosed")

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIfaceFactory.py   PyRQ(Download)
'''
 
from PyRQ.Iface.PyRQIface import PyRQIface
from PyRQ.Iface.PyRQIfaceType import PyRQIfaceType
from PyRQ.Iface.QIface import QIface
    def get(type_, *args, **kwargs):
        if type_==PyRQIfaceType.PYRQ:
            return PyRQIface(*args, **kwargs)
        elif type_==PyRQIfaceType.MULTIPROCESSING_QUEUE:
            return QIface(*args, **kwargs)

src/p/y/PyRQ-0.4.1/PyRQ/__init__.py   PyRQ(Download)
    SubprocessQueueServer as PyRQServer
from PyRQ.Core.Utils.PyRQTimeUtils import PyRQTimeUtils
from PyRQ.Iface.PyRQIface import PyRQIface
from PyRQ.Iface.PyRQIfaceFactory import PyRQIfaceFactory
from PyRQ.Iface.PyRQIfaceType import PyRQIfaceType

src/p/y/PyRQ-0.4.1/test/IFace/TestPyRQIfaceFactory.py   PyRQ(Download)
'''
 
from PyRQ.Iface.PyRQIface import PyRQIface
from PyRQ.Iface.PyRQIfaceFactory import PyRQIfaceFactory
from PyRQ.Iface.PyRQIfaceType import PyRQIfaceType