Hubwiz.com
|
Online Course
|
API Manual
pika API Manual
Guide(37)
Section(35)
Method(360)
Class(19)
Attribute(304)
Exception(43)
Function(1)
Guide
Contributors
Asynchronous consumer example
Asynchronous publisher example
Asyncio Consumer
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
Using Delivery Confirmations with the BlockingConnection
Ensuring message delivery with the mandatory flag
Comparing Message Publishing with BlockingConnection and SelectConnection
Connecting to RabbitMQ with Callback-Passing Style
Direct reply-to example
Ensuring well-behaved connection with heartbeat and blocked-connection timeouts
TLS parameters example
TLS parameters example
Tornado Consumer
Twisted Consumer Example
Using URLParameters
Usage Examples
Frequently Asked Questions
Introduction to Pika
Introduction to Pika
asyncio Connection Adapter
BlockingConnection
Connection Adapters
Select Connection Adapter
Tornado Connection Adapter
Twisted Connection Adapter
Channel
Connection
Authentication Credentials
Exceptions
Core Class and Module Documentation
Connection Parameters
pika.spec
Version History
Section
Example Code
Example Connection URLS
Installing Pika
Using Pika
Indices and tables
IO and Event Looping
Continuation-Passing Style
Credentials
Connection Parameters
TCP Backpressure
Adapters
Channel
PlainCredentials
ExternalCredentials
ConnectionParameters
URLParameters
AMQP Specification
1.0.0b1 2018-02-01
0.12.0 2018-06-19
0.11.2 2017-11-30
0.11.1 2017-11-27
0.11.0 2017-07-29
0.10.0 2015-09-02
0.10.0b2 2015-07-15
0.10.0b1 2015-07-10
0.9.14 - 2014-07-11
0.9.13 - 2013-05-15
0.9.12 - 2013-03-18
0.9.11 - 2013-03-17
0.9.10 - 2013-03-16
0.9.9 - 2013-01-29
0.9.8 - 2012-11-18
0.9.7 - 2012-11-11
0.9.6 - 2012-10-29
0.9.5 - 2011-03-29
Method
add_backpressure_callback
add_on_close_callback
add_on_connection_blocked_callback
add_on_connection_unblocked_callback
add_on_open_callback
add_on_open_error_callback
channel
close
set_backpressure_multiplier
add_callback_threadsafe
add_on_connection_blocked_callback
add_on_connection_unblocked_callback
add_timeout
channel
close
process_data_events
remove_timeout
sleep
add_on_cancel_callback
add_on_return_callback
basic_ack
basic_cancel
basic_consume
basic_get
basic_nack
basic_publish
basic_qos
basic_recover
basic_reject
cancel
close
confirm_delivery
consume
exchange_bind
exchange_declare
exchange_delete
exchange_unbind
flow
get_waiting_message_count
publish
queue_bind
queue_declare
queue_delete
queue_purge
queue_unbind
start_consuming
stop_consuming
tx_commit
tx_rollback
tx_select
add_backpressure_callback
add_on_close_callback
add_on_connection_blocked_callback
add_on_connection_unblocked_callback
add_on_open_callback
add_on_open_error_callback
channel
close
set_backpressure_multiplier
add_callback
add_on_cancel_callback
add_on_close_callback
add_on_flow_callback
add_on_return_callback
basic_ack
basic_cancel
basic_consume
basic_get
basic_nack
basic_publish
basic_qos
basic_recover
basic_reject
close
confirm_delivery
exchange_bind
exchange_declare
exchange_delete
exchange_unbind
flow
open
queue_bind
queue_declare
queue_delete
queue_purge
queue_unbind
tx_commit
tx_rollback
tx_select
add_backpressure_callback
add_on_close_callback
add_on_connection_blocked_callback
add_on_connection_unblocked_callback
add_on_open_callback
add_on_open_error_callback
channel
close
set_backpressure_multiplier
erase_credentials
response_for
erase_credentials
response_for
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
decode
encode
get_body
get_properties
Class
AsyncioConnection
BlockingConnection
BlockingChannel
SelectConnection
Channel
Connection
PlainCredentials
ExternalCredentials
ConnectionParameters
URLParameters
Access
Basic
BasicProperties
Channel
Confirm
Connection
Exchange
Queue
Tx
Attribute
basic_nack
consumer_cancel_notify
exchange_exchange_bindings
ioloop
is_closed
is_closing
is_open
publisher_confirms
basic_nack
basic_nack_supported
consumer_cancel_notify
consumer_cancel_notify_supported
exchange_exchange_bindings
exchange_exchange_bindings_supported
is_closed
is_open
publisher_confirms
publisher_confirms_supported
channel_number
connection
is_closed
is_open
basic_nack
consumer_cancel_notify
exchange_exchange_bindings
ioloop
is_closed
is_closing
is_open
publisher_confirms
consumer_tags
is_closed
is_closing
is_open
basic_nack
consumer_cancel_notify
exchange_exchange_bindings
is_closed
is_closing
is_open
publisher_confirms
reply_code
reply_text
reply_code
reply_text
backpressure_detection
blocked_connection_timeout
channel_max
client_properties
connection_attempts
credentials
frame_max
heartbeat
host
locale
port
retry_delay
socket_timeout
ssl_options
stack_timeout
tcp_options
virtual_host
backpressure_detection
blocked_connection_timeout
channel_max
client_properties
connection_attempts
credentials
frame_max
heartbeat
host
locale
port
retry_delay
socket_timeout
ssl_options
stack_timeout
tcp_options
virtual_host
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
CLASS
FLAG_APP_ID
FLAG_CLUSTER_ID
FLAG_CONTENT_ENCODING
FLAG_CONTENT_TYPE
FLAG_CORRELATION_ID
FLAG_DELIVERY_MODE
FLAG_EXPIRATION
FLAG_HEADERS
FLAG_MESSAGE_ID
FLAG_PRIORITY
FLAG_REPLY_TO
FLAG_TIMESTAMP
FLAG_TYPE
FLAG_USER_ID
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
INDEX
NAME
synchronous
Exception
AMQPChannelError
AMQPConnectionError
AMQPError
AMQPHeartbeatTimeout
AuthenticationError
BodyTooLongError
ChannelClosed
reply_code
reply_text
ChannelClosedByBroker
ChannelClosedByClient
ChannelError
ChannelWrongStateError
ConnectionBlockedTimeout
ConnectionClosed
reply_code
reply_text
ConnectionClosedByBroker
ConnectionClosedByClient
ConnectionOpenAborted
ConnectionWrongStateError
ConsumerCancelled
DuplicateConsumerTag
DuplicateGetOkCallback
IncompatibleProtocolError
InvalidChannelNumber
InvalidFieldTypeException
InvalidFrameError
InvalidMaximumFrameSize
InvalidMinimumFrameSize
MethodNotImplemented
NackError
NoFreeChannels
ProbableAccessDeniedError
ProbableAuthenticationError
ProtocolSyntaxError
ProtocolVersionMismatch
ReentrancyError
ShortStringTooLong
StreamLostError
UnexpectedFrameError
UnroutableError
UnsupportedAMQPFieldException
Function
has_content