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

All Samples(12)  |  Call(6)  |  Derive(0)  |  Import(6)
@summary: Serves a client talking to a queue.
@attention: This class is NOT thread-safe.

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/BootQueueServer.py   PyRQ(Download)
from PyRQ.Core.Linkage.Linkage import Linkage
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServer import QueueServer, ServerHandlerFactory
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.Core.QueueServer.QueueServerOptions import QueueServerOptions
    kwargs["readTimeout"] = int(options.socketReadTimeout)
    kwargs["loggerModule"] = _loadLoggingModule(options.loggingModule)
    qs = QueueServer(host=options.host,
                     port=options.port,
                     marshaller=MarshallerFactory.get(mt, quiet=quiet),

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQTab.py   PyRQ(Download)
from PyRQ.Core.Messages.DEBUG import DEBUG_START, DEBUG_STOP, DEBUG_SOMETHING, \
    DEBUG_QUERY
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from PyRQ.Core.QueueWriter.QueueWriter import QueueWriter
from PyRQ.Iface.PyRQIface import PyRQIface
        self.q = Queue()
        #    self.qs receives all debugging for a particular PyRQ:
        self.qs = QueueServer(host=self.debugger.host,
                              port=32323,
                              marshaller=MarshallerFactory.get(MarshallerFactory.DEFAULT),

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/Debugger/RRQDebugger.py   PyRQ(Download)
'''
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from PyRQ.RRQ.Debugger.Sinks.FileSink import FileSink
from PyRQ.RRQ.Debugger.Sinks.NullSink import NullSink
    q = Queue()
    m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
    QS = QueueServer(port=22334, target=q, quiet=True, marshaller=m)
    QS.start()
    details = QS.details()

src/p/y/PyRQ-0.4.1/Mock/Debugger/MockDebugger.py   PyRQ(Download)
from Mock.Debugger.iMockDebuggerSink import iMockDebuggerSink
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from multiprocessing.queues import Queue
from multiprocessing.synchronize import RLock
    q = Queue()
    m = MarshallerFactory.get(MarshallerFactory.DEFAULT)
    QS = QueueServer(port=22334, target=q, quiet=True, marshaller=m)
    QS.start()
    details = QS.details()

src/p/y/PyRQ-0.4.1/test/QueueServer/TestQueueServer.py   PyRQ(Download)
from PyRQ.Core.Linkage.Linkage import Linkage
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from PyRQ.Core.QueueServer.QueueServerHandler import QueueServerHandler
from PyRQ.Core.QueueServer.SubprocessQueueServer import SubprocessQueueServer
    def _createQueueServer(self):
        #    Create the QueueServer programatically in our Process (not vi a a shell-out (yet))...
        self.qs = QueueServer(host=self.host,
                              port=self.port,
                              target=self.target,
    def _createQueueServer(self):
        #    Create the QueueServer by using os.system or Subprocess.
        #    Create a reply-to Ping server:
        self.rqs= QueueServer(host=self.host,
                              port=self.portReplyTo,

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/SubprocessQueueServer.py   PyRQ(Download)
from PyRQ.Core.Linkage.Linkage import Linkage
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServer import QueueServer
from PyRQ.Core.QueueServer.QueueServerOptions import QueueServerOptions
from PyRQ.Core.QueueServer.iQueueServerDetails import iQueueServerDetails