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

All Samples(210)  |  Call(197)  |  Derive(0)  |  Import(13)
Connection parameters object that is passed into the connection adapter
upon construction.

:param str host: Hostname or IP Address to connect to
:param int port: TCP port to connect to
:param str virtual_host: RabbitMQ virtual host to use
:param pika.credentials.Credentials credentials: auth credentials
:param int channel_max: Maximum number of channels to allow
:param int frame_max: The maximum byte size for an AMQP frame
:param int heartbeat_interval: How often to send heartbeats(more...)

src/p/l/plaidcloud_agent-HEAD/examples/fib_client.py   plaidcloud_agent(Download)
        self.connecting = True
        creds = pika.PlainCredentials('guest', 'guest')
        params = pika.ConnectionParameters(host='localhost', port=5672,
                                           virtual_host='/', credentials=creds)
        self.connection = TornadoConnection(params,

src/p/l/plaidcloud_agent-HEAD/plaidcloud_agent/core/utility/queue.py   plaidcloud_agent(Download)
 
        self.connection_parameters = pika.ConnectionParameters(
            host=RMQ_HOST_NAME,
            port=RMQ_PORT,
            ssl=False,

src/k/u/Kuyruk-0.24.3/kuyruk/__init__.py   Kuyruk(Download)
    def _connect(self):
        """Returns new connection object."""
        parameters = pika.ConnectionParameters(
            host=self.config.RABBIT_HOST,
            port=self.config.RABBIT_PORT,

src/s/y/synapse-client-HEAD/syncli/api/transport.py   synapse-client(Download)
 
        try:
            parameters = pika.ConnectionParameters(host=self.endpoint,
                                                   port=port,
                                                   virtual_host=self.vhost,
                                                   credentials=credentials,
                                                   ssl=self.use_ssl,
                                                   ssl_options=ssl_options)
        except TypeError:
            parameters = pika.ConnectionParameters(host=self.endpoint,

src/k/u/kuyruk-HEAD/kuyruk/__init__.py   kuyruk(Download)
    def _connect(self):
        """Returns new connection object."""
        parameters = pika.ConnectionParameters(
            host=self.config.RABBIT_HOST,
            port=self.config.RABBIT_PORT,

src/g/o/gocept.amqprun-0.13.0/src/gocept/amqprun/connection.py   gocept.amqprun(Download)
                parameters.username, parameters.password)
        self._pika_parameters = pika.ConnectionParameters(
            host=parameters.hostname,
            port=parameters.port,
            virtual_host=parameters.virtual_host,

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.respcon = pika.BlockingConnection(pika.ConnectionParameters(
                                                           host=self.address))
        self.respchan = self.respcon.channel()
        self.respchan.exchange_declare(exchange=self.exchange,type='fanout')

src/c/k/ckanext-harvest-HEAD/ckanext/harvest/queue.py   ckanext-harvest(Download)
 
    credentials = pika.PlainCredentials(userid, password)
    parameters = pika.ConnectionParameters(host=hostname,
                                           port=port,
                                           virtual_host=virtual_host,

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/i/a/iampq-0.0.dev6/iampq/conn.py   iampq(Download)
            password=password)
        params = pika.ConnectionParameters(
            host=host,
            port=port,
            virtual_host='/',

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