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

All Samples(22)  |  Call(16)  |  Derive(0)  |  Import(6)
The TornadoConnection runs on the Tornado IOLoop. If you're running the
connection in a web app, make sure you set stop_ioloop_on_close to False,
which is the default behavior for this adapter, otherwise the web app
will stop taking requests.

:param pika.connection.Parameters parameters: Connection parameters
:param on_open_callback: The method to call when the connection is open
:type on_open_callback: method
:param on_open_error_callback: Method to call if the connection cant
                               be opened(more...)

src/p/l/plaidcloud_agent-HEAD/examples/fib_client.py   plaidcloud_agent(Download)
import tornado.web
 
from pika.adapters.tornado_connection import TornadoConnection
 
# Use the git repository if this file is in it.
        params = pika.ConnectionParameters(host='localhost', port=5672,
                                           virtual_host='/', credentials=creds)
        self.connection = TornadoConnection(params,
                                            on_open_callback=self.on_connect)
        self.connection.add_on_close_callback(self.on_closed)

src/t/o/tornado-celery-0.3.2/tcelery/connection.py   tornado-celery(Download)
import logging
 
from pika.adapters.tornado_connection import TornadoConnection
from pika.exceptions import AMQPConnectionError
 
        params = pika.ConnectionParameters(**options)
        try:
            TornadoConnection(params, stop_ioloop_on_close=False,
                              on_open_callback=partial(self.on_connect, callback),
                              custom_ioloop=self.io_loop)

src/t/o/tornado-celery-HEAD/tcelery/connection.py   tornado-celery(Download)
import logging
 
from pika.adapters.tornado_connection import TornadoConnection
from pika.exceptions import AMQPConnectionError
 
        params = pika.ConnectionParameters(**options)
        try:
            TornadoConnection(params, stop_ioloop_on_close=False,
                              on_open_callback=partial(self.on_connect, callback),
                              custom_ioloop=self.io_loop)

src/r/e/rejected-3.3.0/rejected/process.py   rejected(Download)
                                                    config[name]['user'],
                                                    config[name]['pass'])
        return tornado_connection.TornadoConnection(parameters,
                                                    self.on_connection_open,
                                                    stop_ioloop_on_close=True)

src/r/e/rejected-3.3.0/rejected/consumer.py   rejected(Download)
                                                    config[name]['user'],
                                                    config[name]['pass'])
        return tornado_connection.TornadoConnection(parameters,
                                                    callback,
                                                    stop_ioloop_on_close=False)

src/r/e/rejected-HEAD/rejected/process.py   rejected(Download)
                                                    config[name]['user'],
                                                    config[name]['pass'])
        return tornado_connection.TornadoConnection(parameters,
                                                    self.on_connection_open,
                                                    stop_ioloop_on_close=True)

src/r/e/rejected-HEAD/rejected/consumer.py   rejected(Download)
                                                    config[name]['user'],
                                                    config[name]['pass'])
        return tornado_connection.TornadoConnection(parameters,
                                                    callback,
                                                    stop_ioloop_on_close=False)

src/d/j/django-sockjs-server-0.1.9/django_sockjs_server/lib/pika_client.py   django-sockjs-server(Download)
from django.utils.timezone import now
import pika
from pika.adapters.tornado_connection import TornadoConnection
from pika.exceptions import AMQPConnectionError
import time
 
        try:
            self.connection = TornadoConnection(param,
                                                on_open_callback=self.on_connected)
            self.connection.add_on_close_callback(self.on_closed)

src/d/j/django-sockjs-server-HEAD/django_sockjs_server/lib/pika_client.py   django-sockjs-server(Download)
from django.utils.timezone import now
import pika
from pika.adapters.tornado_connection import TornadoConnection
from pika.exceptions import AMQPConnectionError
import time
 
        try:
            self.connection = TornadoConnection(param,
                                                on_open_callback=self.on_connected)
            self.connection.add_on_close_callback(self.on_closed)

src/d/j/django-bagou-0.0.1/bagou/client.py   django-bagou(Download)
from django.conf import settings
 
from pika.adapters.tornado_connection import TornadoConnection
 
logger = logging.getLogger("pika")
            credentials=cred)
 
        self.connection = TornadoConnection(param, on_open_callback=self.on_connected)
        self.connection.add_on_close_callback(self.on_closed)
 

  1 | 2  Next