Apexmq

---

**Improvements**

1. **Enhanced Consumer Management:**
- Introduced class-based consumer support, allowing for automatic discovery and registration of consumers defined in `your_app/consumers.py`.
- Added support for handling multiple actions in a single consumer class with intuitive method mappings (e.g., `prefix.created` → `created()`).

2. **Advanced Producer Capabilities:**
- Implemented the `publish` function for sending messages to multiple queues with a single call.
- Introduced the `on_model_action` decorator for dynamic message publishing in response to model actions such as create, update, or delete.

3. **Dynamic Queue Management:**
- Added advanced queue binding and configuration options, enabling dynamic routing scenarios.
- Enhanced flexibility in queue options, such as durability, exclusivity, and auto-acknowledgment.

4. **Improved Developer Experience:**
- Added autoreload functionality in development (`DEBUG` mode), allowing RabbitMQ connections to automatically refresh on code changes.
- Streamlined configuration setup with comprehensive options for RabbitMQ connections, retries, and heartbeat intervals.

---

**Bug Fixes**

1. **Improved Error Handling in Consumers:**
- Addressed issues where errors in consumer methods caused unexpected behavior or unacknowledged messages.
- Implemented robust error logging and retry mechanisms for failed message processing.

2. **Producer Stability Enhancements:**
- Fixed edge cases where messages were not published correctly to all intended queues under high-load conditions.
- Resolved issues with missing action type validation in the `publish` function.

---

**Notes**

This release marks a significant milestone in the evolution of **ApexMQ**, making it easier and more intuitive to work with RabbitMQ in Django projects. The addition of class-based consumers, flexible producers, and dynamic queue management empowers developers to build scalable, message-driven systems with minimal boilerplate.

Key highlights include:
- Simplified consumer registration and action handling.
- Streamlined message publishing across multiple queues.
- Improved debugging and error handling during development.

Developers are encouraged to update to v1.1.0 for a more robust and feature-rich messaging experience, especially in applications requiring high scalability and flexibility.

Improvements:

**1. Enhanced Thread Safety:**
* Implemented thread-local storage for connections, ensuring that each thread uses its own dedicated RabbitMQ connection.
* Resolved issues related to concurrent access of shared connections, significantly improving stability in multi-threaded environments.

**2. Improved Connection Management:**
* Introduced a more robust connection handling mechanism with automatic reconnection capabilities.
* Enhanced error handling for connection failures, reducing the likelihood of service interruptions.

**3. Optimized Consumer Threading:**
* Redesigned consumer implementation to use separate threads for each queue, improving parallelism and reducing the risk of blocking operations.

Bug Fixes:

**1. StreamLostError Handling:**
* Addressed the `StreamLostError` that occurred when connections were unexpectedly closed, implementing graceful reconnection logic.

**2. Thread-related IndexError Resolution:**
* Fixed the `IndexError('pop from an empty deque')` that was occurring due to thread-unsafe operations on shared resources.

Notes:
This release significantly enhances the thread safety and connection reliability of ApexMQ. It addresses critical issues that were causing instability in multi-threaded environments and improves the overall robustness of the library. Users are strongly encouraged to update to this version for a more stable and efficient messaging experience, especially in applications with concurrent operations.

Improvements:

**1. Enhanced Thread Safety:**
* Implemented thread-local storage for connections, ensuring that each thread uses its own dedicated RabbitMQ connection.
* Resolved issues related to concurrent access of shared connections, significantly improving stability in multi-threaded environments.

**2. Improved Connection Management:**
* Introduced a more robust connection handling mechanism with automatic reconnection capabilities.
* Enhanced error handling for connection failures, reducing the likelihood of service interruptions.

**3. Optimized Consumer Threading:**
* Redesigned consumer implementation to use separate threads for each queue, improving parallelism and reducing the risk of blocking operations.

Bug Fixes:

**1. StreamLostError Handling:**
* Addressed the `StreamLostError` that occurred when connections were unexpectedly closed, implementing graceful reconnection logic.

**2. Thread-related IndexError Resolution:**
* Fixed the `IndexError('pop from an empty deque')` that was occurring due to thread-unsafe operations on shared resources.

Notes:
This release significantly enhances the thread safety and connection reliability of ApexMQ. It addresses critical issues that were causing instability in multi-threaded environments and improves the overall robustness of the library. Users are strongly encouraged to update to this version for a more stable and efficient messaging experience, especially in applications with concurrent operations.

Improvements:

**1. Enhanced Thread Safety:**
* Implemented thread-local storage for connections, ensuring that each thread uses its own dedicated RabbitMQ connection.
* Resolved issues related to concurrent access of shared connections, significantly improving stability in multi-threaded environments.

**2. Improved Connection Management:**
* Introduced a more robust connection handling mechanism with automatic reconnection capabilities.
* Enhanced error handling for connection failures, reducing the likelihood of service interruptions.

**3. Optimized Consumer Threading:**
* Redesigned consumer implementation to use separate threads for each queue, improving parallelism and reducing the risk of blocking operations.

Bug Fixes:

**1. StreamLostError Handling:**
* Addressed the `StreamLostError` that occurred when connections were unexpectedly closed, implementing graceful reconnection logic.

**2. Thread-related IndexError Resolution:**
* Fixed the `IndexError('pop from an empty deque')` that was occurring due to thread-unsafe operations on shared resources.

Notes:
This release significantly enhances the thread safety and connection reliability of ApexMQ. It addresses critical issues that were causing instability in multi-threaded environments and improves the overall robustness of the library. Users are strongly encouraged to update to this version for a more stable and efficient messaging experience, especially in applications with concurrent operations.

Bug Fixes:
**1. Publishing Bug Fix:**
- Resolved an issue that prevented certain messages from being published correctly to the designated queues. This fix ensures that all messages are reliably sent, improving the overall stability and reliability of the publishing process.
Notes:
This release focuses on improving the reliability of the publishing functionality while maintaining all previous features and capabilities. Users are encouraged to update to this version for a more stable messaging experience.

Bug Fixes:
**1. Publishing Bug Fix:**
- Resolved an issue that prevented certain messages from being published correctly to the designated queues. This fix ensures that all messages are reliably sent, improving the overall stability and reliability of the publishing process.
Notes:
This release focuses on improving the reliability of the publishing functionality while maintaining all previous features and capabilities. Users are encouraged to update to this version for a more stable messaging experience.