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

All Samples(13)  |  Call(0)  |  Derive(7)  |  Import(6)
The BlockingConnection creates a layer on top of Pika's asynchronous core
providing methods that will block until their expected response has returned.
Due to the asynchronous nature of the `Basic.Deliver` and `Basic.Return` calls
from RabbitMQ to your application, you can still implement
continuation-passing style asynchronous methods if you'd like to receive
messages from RabbitMQ using
:meth:`basic_consume <BlockingChannel.basic_consume>` or if you want  to be
notified of a delivery failure when using
:meth:`basic_publish <BlockingChannel.basic_publish>` .
(more...)

src/k/u/Kuyruk-0.24.3/kuyruk/connection.py   Kuyruk(Download)
import logging
from threading import RLock
from collections import defaultdict
 
from pika.adapters.blocking_connection import (BlockingConnection,
class Connection(BlockingConnection):
 
    def __init__(self, parameters=None):
        self._lock = RLock()
        super(Connection, self).__init__(parameters)

src/s/o/socorro-HEAD/webapp-django/vendor/lib/python/kombu/transport/pika2.py   socorro(Download)
class Connection(blocking.BlockingConnection):
    Channel = Channel
 
    def __init__(self, client, *args, **kwargs):
        self.client = client

src/k/u/kuyruk-HEAD/kuyruk/connection.py   kuyruk(Download)
import logging
from threading import RLock
from collections import defaultdict
 
from pika.adapters.blocking_connection import (BlockingConnection,
class Connection(BlockingConnection):
 
    def __init__(self, parameters=None):
        self._lock = RLock()
        super(Connection, self).__init__(parameters)

src/m/o/mozillians-HEAD/vendor-local/lib/python/kombu/transport/pika2.py   mozillians(Download)
class Connection(blocking.BlockingConnection):
    Channel = Channel
 
    def __init__(self, client, *args, **kwargs):
        self.client = client

src/m/a/make.mozilla.org-HEAD/vendor-local/lib/python/kombu/transport/pika2.py   make.mozilla.org(Download)
class Connection(blocking.BlockingConnection):
    Channel = Channel
 
    def __init__(self, client, *args, **kwargs):
        self.client = client

src/p/l/playdoh-lib-HEAD/lib/python/kombu/transport/pika2.py   playdoh-lib(Download)
class Connection(blocking.BlockingConnection):
    Channel = Channel
 
    def __init__(self, client, *args, **kwargs):
        self.client = client

src/k/u/kuma-lib-HEAD/packages/kombu/kombu/transport/pika2.py   kuma-lib(Download)
class Connection(blocking.BlockingConnection):
    Channel = Channel
 
    def __init__(self, client, *args, **kwargs):
        self.client = client

src/c/a/captain-HEAD/vendor/lib/python/pika/__init__.py   captain(Download)
from pika.adapters.base_connection import BaseConnection
from pika.adapters.asyncore_connection import AsyncoreConnection
from pika.adapters.blocking_connection import BlockingConnection
from pika.adapters.select_connection import SelectConnection
 

src/p/i/pika-HEAD/pika/__init__.py   pika(Download)
from pika.adapters.base_connection import BaseConnection
from pika.adapters.asyncore_connection import AsyncoreConnection
from pika.adapters.blocking_connection import BlockingConnection
from pika.adapters.select_connection import SelectConnection
 

src/o/p/openquake-packages-HEAD/pika-0.9.5/pika/__init__.py   openquake-packages(Download)
from pika.adapters.base_connection import BaseConnection
from pika.adapters.asyncore_connection import AsyncoreConnection
from pika.adapters.blocking_connection import BlockingConnection
from pika.adapters.select_connection import SelectConnection
from pika.adapters.select_connection import IOLoop

  1 | 2  Next