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

All Samples(142)  |  Call(140)  |  Derive(0)  |  Import(2)
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/b/a/BarkingOwl-HEAD/plugins/examples/scraperstatus/requeststatus.py   BarkingOwl(Download)
 
        #setup message bus
        self.reqcon = pika.BlockingConnection(pika.ConnectionParameters(host=address))
        self.reqchan = self.reqcon.channel()
        self.reqchan.exchange_declare(exchange=exchange,type='fanout')
        self.reqchan.basic_consume(self.reqcallback,queue=queue_name,no_ack=True)
 
        self.respcon = pika.BlockingConnection(pika.ConnectionParameters(
                                                           host=self.address))
        self.respchan = self.respcon.channel()

src/b/a/BarkingOwl-HEAD/plugins/examples/diagoutput/diagoutput.py   BarkingOwl(Download)
    def __init__(self,address='localhost',exchange='barkingowl'):
 
        #setup message bus
        self.reqcon = pika.BlockingConnection(pika.ConnectionParameters(host=address))
        self.reqchan = self.reqcon.channel()

src/a/i/aioamqp-HEAD/examples/py2_worker.py   aioamqp(Download)
    ch.basic_ack(delivery_tag=method.delivery_tag)
 
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
 

src/a/i/aioamqp-HEAD/examples/py2_receive_logs_topic.py   aioamqp(Download)
    print(" [x] %r:%r" % (method.routing_key, body,))
 
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
 

src/a/i/aioamqp-HEAD/examples/py2_receive_logs_direct.py   aioamqp(Download)
    print(" [x] %r:%r" % (method.routing_key, body,))
 
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
 

src/a/i/aioamqp-HEAD/examples/py2_receive_logs.py   aioamqp(Download)
 
 
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
 

src/a/i/aioamqp-HEAD/examples/py2_example.py   aioamqp(Download)
import pika
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 

src/a/i/aioamqp-HEAD/examples/py2_consume.py   aioamqp(Download)
    print(" [x] Received %r" % (body,))
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 

src/p/y/python-dtrace-0.0.7/examples/amqp/send.py   python-dtrace(Download)
 
# Connection to the broker
connection = pika.BlockingConnection(pika.ConnectionParameters(
                                     host='localhost'))
channel = connection.channel()

src/p/y/python-dtrace-0.0.7/examples/amqp/receive.py   python-dtrace(Download)
 
# Connection to the broker.
connection = pika.BlockingConnection(pika.ConnectionParameters(
                                     host='localhost'))
channel = connection.channel()

  1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9  Next