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

All Samples(28)  |  Call(28)  |  Derive(0)  |  Import(0)
Disconnect from RabbitMQ. If there are any open channels, it will
attempt to close them prior to fully disconnecting. Channels which
have active consumers will attempt to send a Basic.Cancel to RabbitMQ
to cleanly stop the delivery of messages prior to closing the channel.

:param int reply_code: The code number for the close
:param str reply_text: The text reason for the close

src/a/i/aioamqp-HEAD/examples/py2_example.py   aioamqp(Download)
 
#import ipdb; ipdb.set_trace()
connection.close()
 

src/p/y/python-dtrace-0.0.7/examples/amqp/send.py   python-dtrace(Download)
if __name__ == '__main__':
    run_dtrace()
    connection.close()
 

src/p/y/python-dtrace-0.0.7/examples/amqp/receive.py   python-dtrace(Download)
        channel.start_consuming()
    except KeyboardInterrupt:
        connection.close()
        # You could use Google chart to create a plot aferwards...
        # from GChartWrapper import Pie

src/p/y/python-dtrace-HEAD/examples/amqp/send.py   python-dtrace(Download)
if __name__ == '__main__':
    run_dtrace()
    connection.close()
 

src/p/y/python-dtrace-HEAD/examples/amqp/receive.py   python-dtrace(Download)
        channel.start_consuming()
    except KeyboardInterrupt:
        connection.close()
        # You could use Google chart to create a plot aferwards...
        # from GChartWrapper import Pie

src/r/o/rooibos-HEAD/rooibos/workers/management/commands/runworkers.py   rooibos(Download)
        except KeyboardInterrupt:
            channel.stop_consuming()
        connection.close()
 

src/f/a/fabuloso-1.2/fabuloso/utils.py   fabuloso(Download)
        print " [x] SENT: 'Message test to %s RabbitMQ successfully sent'""" \
              % service_type
        connection.close()
        _receive_rabbitMQ(service_type, host, port, user, password,
                          virtual_host)
        channel.basic_consume(_callback, queue='test', no_ack=True,
                              consumer_tag='consumer')
        connection.close()
    except Exception, e:
        #logging.error('RabbitMQ to %s Test Failed...%s' % (service_type, e))

src/r/a/rabbitmq-tutorials-HEAD/python/send.py   rabbitmq-tutorials(Download)
                      body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()
 

src/r/a/rabbitmq-tutorials-HEAD/python/new_task.py   rabbitmq-tutorials(Download)
                      ))
print " [x] Sent %r" % (message,)
connection.close()
 

src/r/a/rabbitmq-tutorials-HEAD/python/emit_log_topic.py   rabbitmq-tutorials(Download)
                      body=message)
print " [x] Sent %r:%r" % (routing_key, message)
connection.close()
 

  1 | 2 | 3  Next