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

All Samples(6)  |  Call(0)  |  Derive(4)  |  Import(2)
This is the core class that implements communication with RabbitMQ. This
class should not be invoked directly but rather through the use of an
adapter such as SelectConnection or BlockingConnection.

:param pika.connection.Parameters parameters: Connection parameters
:param method on_open_callback: Called when the connection is opened
:param method on_open_error_callback: Called if the connection cant
                               be opened
:param method on_open_callback: Called when the connection is closed

src/o/p/openquake-packages-HEAD/pika-0.9.5/pika/adapters/base_connection.py   openquake-packages(Download)
import time
 
from pika.connection import Connection
import pika.log
 
class BaseConnection(Connection):
 
    def __init__(self, parameters=None, on_open_callback=None,
                 reconnection_strategy=None):
        # Set our defaults

src/c/a/captain-HEAD/vendor/lib/python/pika/adapters/base_connection.py   captain(Download)
class BaseConnection(connection.Connection):
    """BaseConnection class that should be extended by connection adapters"""
 
    # Use epoll's constants to keep life easy
    READ = 0x0001

src/p/i/pika-0.9.13/pika/adapters/base_connection.py   pika(Download)
class BaseConnection(connection.Connection):
    """BaseConnection class that should be extended by connection adapters"""
 
    # Use epoll's constants to keep life easy
    READ = 0x0001

src/p/i/pika-HEAD/pika/adapters/base_connection.py   pika(Download)
class BaseConnection(connection.Connection):
    """BaseConnection class that should be extended by connection adapters"""
 
    # Use epoll's constants to keep life easy
    READ = 0x0001

src/p/y/pyon-HEAD/pyon/net/test/test_messaging.py   pyon(Download)
from mock import Mock, sentinel, patch
from nose.plugins.attrib import attr
from pika.connection import Connection
from pyon.core import bootstrap
from pyon.util.int_test import IonIntegrationTestCase