RbFly - RabbitMQ Client Library

RbFly is a library for RabbitMQ Streams using Python asyncio.

RbFly Library

• 1. Overview
  • 1.1. Features
  • 1.2. Requirements
  • 1.3. Installation
  • 1.4. Documentation
  • 1.5. Links
  • 1.6. Acknowledgements
• 2. License
  • 2.1. Proprietary License
• 3. Quick Start

Topics

• 1. Publish Messages
  • 1.1. Send Single Message
  • 1.2. Send Batch of Messages
  • 1.3. Fast Batch Publishing
  • 1.4. Publishing Exceptions
• 2. Read Messages
  • 2.1. Subscribe to a Stream
  • 2.2. Message Context
  • 2.3. Offset Specification
  • 2.4. Offset Reference
• 3. Manage Connection
• 4. Deduplicate Messages
  • 4.1. Publish Messages with Id
  • 4.2. Order of Messages
• 5. Filter Messages
  • 5.1. Publish and Read with Filtering
  • 5.2. Filtering Considerations
• 6. Manage Streams
  • 6.1. RabbitMQ CLI Tools
  • 6.2. Automation Tools
  • 6.3. RbFly API
• 7. Concurrency and Parallelism
  • 7.1. Asynchronous Concurrency
  • 7.2. Threads
  • 7.3. Example of Parallelism
• 8. Performance Report
  • 8.1. Publishing Messages
    • 8.1.1. Results
    • 8.1.2. Test Scenario
  • 8.2. Publishing Messages in AMQP Format
    • 8.2.1. Results
    • 8.2.2. Test Scenario
  • 8.3. Encoding and Decoding with AMQP Codec
    • 8.3.1. Results
    • 8.3.2. Test Scenario
  • 8.4. Testing Environment
    • 8.4.1. Software Components
    • 8.4.2. Hardware Configuration

Reference

• 1. RabbitMQ Streams API
  • 1.1. Broker Connection API
    • streams_client()
    • connection()
    • StreamsClient
      • StreamsClient.create_stream()
      • StreamsClient.delete_stream()
      • StreamsClient.publisher()
      • StreamsClient.subscribe()
      • StreamsClient.write_offset()
    • AuthMechanism
  • 1.2. Publisher and Subscriber API
    • stream_message_ctx()
    • get_message_ctx()
    • Publisher
      • Publisher.name
      • Publisher.stream
      • Publisher.message_id
      • Publisher.send()
    • PublisherBatchLimit
      • PublisherBatchLimit.name
      • PublisherBatchLimit.stream
      • PublisherBatchLimit.message_id
      • PublisherBatchLimit.batch()
      • PublisherBatchLimit.flush()
    • PublisherBatchFast
      • PublisherBatchFast.name
      • PublisherBatchFast.stream
      • PublisherBatchFast.message_id
      • PublisherBatchFast.batch()
      • PublisherBatchFast.flush()
    • MessageCtx
    • Offset
      • Offset.FIRST
      • Offset.LAST
      • Offset.NEXT
      • Offset.offset()
      • Offset.reference()
      • Offset.timestamp()
    • MessageFilter
    • BloomFilterExtract
  • 1.3. Data Types
    • Symbol
    • AMQPScalar
    • AMQPBody
    • AMQPAnnotations
    • AMQPAppProperties
  • 1.4. Deprecated API
    • PublisherBatch
    • PublisherBatchMem
• 2. Connection URI
• 3. Message Data Types
• 4. Changelog
  • 4.1. Year 2025
    • 4.1.1. 2025-11-04, ver. 0.11.0
  • 4.2. Year 2024
    • 4.2.1. 2024-10-17, ver. 0.10.0
    • 4.2.2. 2024-07-11, ver. 0.9.0
    • 4.2.3. 2024-05-21, ver. 0.8.4
    • 4.2.4. 2024-05-04, ver. 0.8.3
    • 4.2.5. 2024-03-19, ver. 0.8.2
    • 4.2.6. 2024-01-07, ver. 0.8.1
  • 4.3. Year 2023
    • 4.3.1. 2023-11-02, ver. 0.8.0
    • 4.3.2. 2023-09-15, ver. 0.7.3
    • 4.3.3. 2023-07-09, ver. 0.7.2
    • 4.3.4. 2023-06-25, ver. 0.7.1
    • 4.3.5. 2023-06-21, ver. 0.7.0
    • 4.3.6. 2023-05-12, ver. 0.6.2
    • 4.3.7. 2023-03-18, ver. 0.6.1
    • 4.3.8. 2023-02-04, ver. 0.6.0
  • 4.4. Year 2022
    • 4.4.1. 2022-12-22, ver. 0.5.6
    • 4.4.2. 2022-12-19, ver. 0.5.5
    • 4.4.3. 2022-11-23, ver. 0.5.4
    • 4.4.4. 2022-11-11, ver. 0.5.3
    • 4.4.5. 2022-11-01, ver. 0.5.2
    • 4.4.6. 2022-10-16, ver. 0.5.1
    • 4.4.7. 2022-10-09, ver. 0.5.0
    • 4.4.8. 2022-09-12, ver. 0.4.2
    • 4.4.9. 2022-08-16, ver. 0.4.1
    • 4.4.10. 2022-08-16, ver. 0.4.0
    • 4.4.11. 2022-05-23, ver. 0.3.0
    • 4.4.12. 2022-05-13, ver. 0.2.0
    • 4.4.13. 2022-04-13, ver. 0.1.1
    • 4.4.14. 2022-04-06, ver. 0.1.0
    • 4.4.15. 2022-03-25, ver. 0.0.4
    • 4.4.16. 2022-03-24, ver. 0.0.3
    • 4.4.17. 2022-01-24, ver. 0.0.2
    • 4.4.18. 2022-01-16, ver. 0.0.1

• Index