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
    • Blocking.__init__()
    • Blocking.connection
    • Blocking.channel
    • Blocking.declare_queue()
    • Blocking.consume()
    • Blocking.channel_cancel_callback()
    • Blocking.add_signal_handler()
    • Blocking.interrupt()
    • Blocking.close()
  • Async
    • Async.__init__()
    • Async.custom_ioloop
    • Async.manage_ioloop
    • Async.executor
    • Async.blocked
    • Async.stopping
    • Async.ready
    • 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
  • decorate()
  • halt()
  • discard()
  • requeue()
• Channel methods
  • publish()
  • ack()
  • nack()
  • add_callback_threadsafe()
• Utilities
  • json_dumps()
  • default_decode()
  • default_encode()
  • basic_publish_kwargs()
  • basic_publish_debug_args()
• Types
  • State
    • State.format_routing_key
    • State.interrupt
    • State.connection
    • State.exchange
    • State.encode
    • State.content_type
    • State.delivery_mode
  • PublishKeywords
    • PublishKeywords.exchange
    • PublishKeywords.routing_key
    • PublishKeywords.body
    • PublishKeywords.properties