API reference#
- Clients
Base
Base.connection
Base.channel
Base.__safe__
Base.__init__()
Base.parameters
Base.durable
Base.exchange
Base.exchange_type
Base.prefetch_count
Base.decode
Base.encode
Base.content_type
Base.routing_key_template
Base.delivery_mode
Base.consumer_tag
Base.format_routing_key()
Base.publish()
Base.add_signal_handlers()
Base.add_signal_handler()
Base.interrupt()
Base.state
Blocking
Async
Async.__init__()
Async.executor
Async.blocked
Async.stopping
Async.thread_name_infix
Async.start()
Async.connect()
Async.connection_blocked_callback()
Async.connection_unblocked_callback()
Async.reconnect()
Async.reset()
Async.connection_open_error_callback()
Async.connection_close_callback()
Async.add_signal_handler()
Async.interrupt()
Async.connection_open_callback()
Async.channel_open_callback()
Async.channel_cancelok_callback()
Async.channel_close_callback()
Async.channel_qosok_callback()
Async.exchange_declareok_callback()
Async.exchange_ready()
AsyncConsumer
AsyncConsumer.__init__()
AsyncConsumer.queue
AsyncConsumer.routing_keys
AsyncConsumer.arguments
AsyncConsumer.on_message_callback
AsyncConsumer.decorator
AsyncConsumer.thread_name_infix
AsyncConsumer.exchange_ready()
AsyncConsumer.queue_declareok_callback()
AsyncConsumer.queue_bindok_callback()
AsyncConsumer.consume()
AsyncConsumer.channel_cancel_callback()
AsyncConsumer.channel_consumeok_callback()
- Decorators
- Channel methods
- Utilities
- Types