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

All Samples(14)  |  Call(7)  |  Derive(0)  |  Import(7)

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/QueueServer.py   PyRQ(Download)
 
from PyRQ.Core.Marshal.MarshallerFactory import MarshallerFactory
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.Core.QueueServer.QueueServerHandler import QueueServerHandler
from PyRQ.Core.QueueServer.iQueueServer import iQueueServer
    def details(self):
        return QueueServerDetails(self._host, self._port, namespace=self._namespace)
 
 

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/__init__.py   PyRQ(Download)
 
from PyRQ import PyRQServer
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.Ui.qt4.RRQDebugger.RRQDebugger import RRQDebugger
from optparse import OptionParser
    for detail in details:
        params = detail.split(":")
        allDetails.append(QueueServerDetails(params[0], port=int(params[1])))
    print "quiet: %(Q)s"%{"Q":quiet}
    print "host: %(Q)s"%{"Q":host}

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/RRQDebugger.py   PyRQ(Download)
 
from PyQt4 import QtGui, QtCore, uic, Qt
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.Ui.qt4.RRQDebugger.AboutDialog import AboutDialog
from PyRQ.Ui.qt4.RRQDebugger.FiltererEnablers import Enablers
        self.logger = self._getLogger("Debugger", self.loggingLevel)
        self.tabs = []
        self._backupDetails = QueueServerDetails(host, 11223)
        self.author = "root"
        self.lock = RLock()

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/PyRQSelectorDialog.py   PyRQ(Download)
 
from PyQt4 import QtGui, Qt, QtCore
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.RRQ.Debugger.PING import PING
from PyRQ.Ui.qt4.RRQDebugger.RRQTab import RRQTab
    def _getDetails(self):
        try:
            host = str(self.lineEdit_host.text().toAscii())
            port = int(self.spinBox_port.value())
            details = QueueServerDetails(host, port)

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/InternalState.py   PyRQ(Download)
'''
 
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
from PyRQ.Ui.qt4.RRQDebugger.Failed import Failed
import pickle
                            (port, isValid) = port.toUInt()
                            if isValid:
                                self.details[key] = QueueServerDetails(host, int(port))
                finally:
                    self.settings.endGroup()

src/p/y/PyRQ-0.4.1/PyRQ/Core/QueueServer/BootQueueServer.py   PyRQ(Download)
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
from PyRQ.Core.Utils.ImportUtils import _getClass, _importModule, \
#        import pydevd
#        pydevd.settrace(stdoutToServer = True, stderrToServer = True)
        qw = QueueWriter(target=QueueServerDetails(options.ackHost, options.ackPort),
                        marshaller=MarshallerFactory.get(mt, quiet=quiet),
                        autoConnect=True,

src/p/y/PyRQ-0.4.1/PyRQ/Iface/QIface.py   PyRQ(Download)
from multiprocessing.queues import Queue
import itertools
from PyRQ.Core.QueueServer.QueueServerDetails import QueueServerDetails
 
class QIface(iPyRQIface):
    def getDescription(self):
        return QueueServerDetails("multiprocessing.queue")
    def keepAlive(self, enabler):
        return
    def getFixedTimeout(self):