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

All Samples(14)  |  Call(14)  |  Derive(0)  |  Import(0)
Connect to RabbitMQ via an AMQP URL in the format::

     amqp://username:password@host:port/<virtual_host>[?query-string]

Ensure that the virtual host is URI encoded when specified. For example if
you are using the default "/" virtual host, the value should be `%2f`.

Valid query string values are:

    - backpressure_detection:(more...)

src/p/i/pikachu-0.1.9/pikachu/__init__.py   pikachu(Download)
    def __init__(self, conn_string):
        self.connection = pika.BlockingConnection(pika.URLParameters(conn_string))
        self.channel = self.connection.channel()
        result = self.channel.queue_declare(exclusive=True)
        self.callback_queue = result.method.queue
    def start(self, conn_string):
        try:
            parameters = pika.URLParameters(conn_string)
            connection = pika.SelectConnection(parameters=parameters, on_open_callback=self.on_connected)
        except:

src/c/o/contexture-1.3.1/contexture/monitor.py   contexture(Download)
            params = pika.ConnectionParameters()
            if url:
                params = pika.URLParameters(url)
            if socket_timeout:
                params.socket_timeout = socket_timeout

src/m/a/max-3.6/max/rabbitmq/notifications.py   max(Download)
    if rabbitmq_url:
        connection = pika.BlockingConnection(
            pika.URLParameters(rabbitmq_url)
        )
        channel = connection.channel()
        }
        connection = pika.BlockingConnection(
            pika.URLParameters(rabbitmq_url)
        )
        channel = connection.channel()
    if rabbitmq_url:
        connection = pika.BlockingConnection(
            pika.URLParameters(rabbitmq_url)
        )
        channel = connection.channel()

src/c/o/contexture-1.3.1/contexture/backend/amqp.py   contexture(Download)
                 reconnect_wait=10):
        if url:
            self._conn_params = pika.URLParameters(url)
        else:
            creds = pika.credentials.PlainCredentials(user, password)

src/s/u/suricate-HEAD/ui/api.py   suricate(Download)
    def __init__(self, uri):
        self.para = pika.URLParameters(uri)
        self.connection = pika.BlockingConnection(self.para)
 
        self.corr_id = None

src/s/u/suricate-HEAD/analytics/exec_node.py   suricate(Download)
 
        # connect to AMQP broker
        connection = pika.BlockingConnection(pika.URLParameters(amqp_uri))
        self.channel = connection.channel()
        self.channel.queue_declare(queue=uid)

src/s/u/suricate-HEAD/data/streaming.py   suricate(Download)
        # amqp conn.
        self.queue = queue
        connection = pika.BlockingConnection(pika.URLParameters(amqp_uri))
        self.channel = connection.channel()
        self.channel.queue_declare(queue=queue)

src/a/g/agentredrabbit-HEAD/agentredrabbit/transport.py   agentredrabbit(Download)
        conn = None
        try:
            conn = pika.SelectConnection(pika.URLParameters(self.amqp_url),
                                         self.on_connection_open,
                                         stop_ioloop_on_close=False)

src/a/a/aamnotifs-0.1.0/aamnotifs/__init__.py   aamnotifs(Download)
    def connect(self, url):
        try:
            self.connection = pika.BlockingConnection(pika.URLParameters(url))
            self.channel = self.connection.channel()
            self.channel.exchange_declare(exchange=self.exchange, type='topic')

src/s/h/shoal-server-0.6.1/shoal_server/shoal.py   shoal-server(Download)
    def connect(self):
        try:
            return pika.SelectConnection(pika.URLParameters(self.host),
                                             self.on_connection_open,
                                             stop_ioloop_on_close=False)

  1 | 2  Next