blazingmq

blazingmq is the official way to interact with the BlazingMQ framework from Python.

Contents

• User Guide
  • Simple Producer
  • Simple Consumer
  • Host Health Monitoring
• Examples
  • Producer
  • Consumer with threading.Event
  • Consumer with queue.Queue
• Acknowledgments
• Message Properties
  • Posting
    • Message With Properties
    • Properties With Overrides
  • Consuming
• Queue Options and Configuration
  • Setting Queue Options
  • Common Scenarios
    • Pausing consumption on demand
    • Delivering all messages to one consumer
• API Reference
  • Session
    • Session
      • Session.close_queue()
      • Session.configure_queue()
      • Session.confirm()
      • Session.get_queue_options()
      • Session.open_queue()
      • Session.post()
      • Session.stop()
      • Session.with_options()
    • Timeouts
    • SessionOptions
    • QueueOptions
      • QueueOptions.DEFAULT_MAX_UNCONFIRMED_MESSAGES
      • QueueOptions.DEFAULT_MAX_UNCONFIRMED_BYTES
      • QueueOptions.DEFAULT_CONSUMER_PRIORITY
      • QueueOptions.DEFAULT_SUSPENDS_ON_BAD_HOST_HEALTH
  • Message Classes
    • Message
      • Message.data
      • Message.guid
      • Message.queue_uri
      • Message.properties
      • Message.property_types
    • MessageHandle
      • MessageHandle.confirm()
    • Ack
      • Ack.guid
      • Ack.queue_uri
      • Ack.status
  • Health Monitoring
    • BasicHealthMonitor
      • BasicHealthMonitor.set_healthy()
      • BasicHealthMonitor.set_unhealthy()
  • Enumerations
    • AckStatus
      • AckStatus.SUCCESS
      • AckStatus.CANCELED
      • AckStatus.INVALID_ARGUMENT
      • AckStatus.LIMIT_BYTES
      • AckStatus.LIMIT_MESSAGES
      • AckStatus.NOT_CONNECTED
      • AckStatus.NOT_READY
      • AckStatus.NOT_SUPPORTED
      • AckStatus.REFUSED
      • AckStatus.TIMEOUT
      • AckStatus.UNKNOWN
      • AckStatus.UNRECOGNIZED
    • CompressionAlgorithmType
      • CompressionAlgorithmType.NONE
      • CompressionAlgorithmType.ZLIB
    • PropertyType
      • PropertyType.BOOL
      • PropertyType.CHAR
      • PropertyType.SHORT
      • PropertyType.INT32
      • PropertyType.INT64
      • PropertyType.STRING
      • PropertyType.BINARY
  • Exceptions
    • Error
    • BrokerTimeoutError
  • Session Events
    • SessionEvent
    • QueueEvent
      • QueueEvent.queue_uri
    • Connected
    • Disconnected
    • ConnectionLost
    • Reconnected
    • StateRestored
    • ConnectionTimeout
    • HostUnhealthy
    • HostHealthRestored
    • QueueSuspended
      • QueueSuspended.queue_uri
    • QueueSuspendFailed
      • QueueSuspendFailed.queue_uri
    • QueueResumed
      • QueueResumed.queue_uri
    • QueueResumeFailed
      • QueueResumeFailed.queue_uri
    • QueueReopened
      • QueueReopened.queue_uri
    • QueueReopenFailed
      • QueueReopenFailed.queue_uri
    • SlowConsumerNormal
    • SlowConsumerHighWaterMark
    • Error
    • InterfaceError
  • Helper Functions
    • log_session_event()
  • Testing Utilities
    • HostHealth
  • Helper Types
    • PropertyTypeDict
    • PropertyValueDict
• Changelog
• Build instructions
  • Using make vs. tox
  • Local Development
  • Working with Make Targets

Indices and tables

• Index

• Module Index

• Search Page