connection.ioloop.start()
method.IOLoop
you invoke it normally and then add the Pika Tornado adapter to it.channel.basic_consume
telling it to call the handle_delivery for each message RabbitMQ delivers to us.pika.credentials
module provides the mechanism by which you pass the username and password to the ConnectionParameters
class when it is created.ConnectionParameters
and URLParameters
. Both classes share the same default connection values.add_backpressure_callback
method of any connection adapter, your function will be called when Pika sees that a backlog of 10 times the average frame size you have been sending has been exceeded. You may tweak the notification multiplier value by calling the set_backpressure_multiplier
method passing any integer value.[1] | “more effective flow control mechanism that does not require cooperation from clients and reacts quickly to prevent the broker from exhausting memory - see http://lists.rabbitmq.com/pipermail/rabbitmq-announce/attachments/20100825/2c672695/attachment.txt |