PyRQ.Core.Errors.PyRQError

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

@summary: Unable to communicate with the PyRQ instance.
Queue already closed.
Failed to create the queue via the PyRQ in the given timeout.
Failed to marshall and send data to the PyRQ.
Any unhandled error whilst communicating with the PyRQ.

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py PyRQ(Download)

                if not self._quiet: self._logger.error("create CLOSED: %(E)s from: %(W)s"%{"E":e, "W":sockDetails})
                self._closed=True
                raise Errors.PyRQError(e)
            except (_Timeout, Errors.Finished), e:
                self._logger.error("create unable to create: %(E)s from: %(W)s"%{"E":e, "W":sockDetails})
                raise Errors.PyRQError(e)

            except Exception, e:
                if not self._quiet: self._logger.error("qsize unable to qsize: %(E)s from %(W)s"%{"E":e, "W":sockDetails})
                raise Errors.PyRQError(e)
            else:
                if not self._quiet: self._logger.info("qsize OK %(S)s"%{"S":qSize})

            except Exception, e:
                if not self._quiet: self._logger.error("maxQSize unable to maxQSize: %(E)s from %(W)s"%{"E":e, "W":sockDetails})
                raise Errors.PyRQError(e)
            else:
                if not self._quiet: self._logger.info("maxQSize OK %(S)s"%{"S":maxQSize})

        except Exception, e:
            self._logger.error("_sendData[0]: %(E)s from: %(W)s"%{"E":e, "W":self._sock.getsockname()})
            raise Errors.PyRQError(e)
        try:
            self._sock.sendall(d)