Usage Examples

Pika has various methods of use, between the synchronous BlockingConnection adapter and the various asynchronous connection adapter. The following examples illustrate the various ways that you can use Pika in your projects.

• Using URLParameters
• Connecting to RabbitMQ with Callback-Passing Style
• Using the Blocking Connection to get a message from RabbitMQ
• Using the Blocking Connection to consume messages from RabbitMQ
• Using the Blocking Connection with connection recovery with multiple hosts
• Using the BlockingChannel.consume generator to consume messages
• Comparing Message Publishing with BlockingConnection and SelectConnection
• Using Delivery Confirmations with the BlockingConnection
• Ensuring message delivery with the mandatory flag
• Asynchronous consumer example
• Asynchronous publisher example
• Asyncio consumer example
• Twisted consumer example
• Tornado consumer example
• TLS parameters example
• TLS parameters example
• Ensuring well-behaved connection with heartbeat and blocked-connection timeouts
• Direct reply-to example