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

All Samples(11)  |  Call(4)  |  Derive(2)  |  Import(5)

src/s/y/synapse-agent-HEAD/synapse/amqp.py   synapse-agent(Download)
from datetime import datetime, timedelta
 
from pika.adapters import SelectConnection
from pika.adapters.select_connection import SelectPoller
from pika.credentials import PlainCredentials, ExternalCredentials
    def connect(self):
        SelectPoller.TIMEOUT = float(self.poller_delay)
        return SelectConnection(self.parameters, self.on_connection_open,
                                stop_ioloop_on_close=False)
 

src/z/a/zato-HEAD/code/zato-server/src/zato/server/connection/amqp/__init__.py   zato(Download)
 
# Pika
from pika.adapters import SelectConnection
from pika.connection import ConnectionParameters
from pika.credentials import PlainCredentials
    def _start(self):
        self.conn = SelectConnection(self.conn_params, self._on_connected)
        self.conn.ioloop.start()
 
    def _close(self):

src/d/j/django-greenqueue-HEAD/greenqueue/backends/rabbitmq.py   django-greenqueue(Download)
from .. import settings, shortcuts
 
from pika.adapters import SelectConnection
 
import logging
    def create_async_connection(self):
        return SelectConnection(self.create_connection_params(), self._on_connected)
 
    def send(self, name, args=[], kwargs={}, eta=None, countdown=None):
        connection = self.create_blocking_connection()

src/p/y/pyon-HEAD/prototype/speed/pikaserv.py   pyon(Download)
if __name__ == '__main__':
    parameters = pika.ConnectionParameters('localhost')
    connection = pika.adapters.SelectConnection(parameters, on_connected)
    try:
        connection.ioloop.start()

src/s/l/sleipnir.transport-0.1.0/src/sleipnir/transport/amqp/connections.py   sleipnir.transport(Download)
# Import here any required modules.
from pika import PlainCredentials, ConnectionParameters
from pika.adapters import SelectConnection
 
__all__ = []
class ConnectionAMQP(PikaConnection, SelectConnection):
 
    CONNECTION_TYPE = ConnectionType.AMQP_ASYNC
 
    def __init__(self, url):

src/p/y/pyon-HEAD/pyon/net/messaging.py   pyon(Download)
from pika.credentials import PlainCredentials
from pika.connection import ConnectionParameters
from pika.adapters import SelectConnection
from pika import channel as pikachannel
from pika.exceptions import NoFreeChannels
class PyonSelectConnection(SelectConnection):
    """
    Custom-derived Pika SelectConnection to allow us to get around re-using failed channels.
 
    When a Channel fails, if the channel number is reused again, sometimes Pika/Rabbit will