PyRQ.Core.QueueServer.QueueServer.QueueServer

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