Laravel Rabbitmq Laravel Package

What's Changed

• Add production RabbitMQ configuration, Horizon support, and reliability upgrades by @iamfarhad in https://github.com/iamfarhad/LaravelRabbitMQ/pull/14
• Remove static analysis from GitHub Actions by @iamfarhad in https://github.com/iamfarhad/LaravelRabbitMQ/pull/15

v1.3.0

Highlights

This release upgrades Laravel RabbitMQ into a more production-focused queue driver with stronger RabbitMQ topology support, better Laravel ecosystem integration, and improved reliability.

Added

• Multi-host RabbitMQ configuration support while preserving the previous single-host config format.
• Read, write, and connect timeout configuration.
• Configurable exchange, exchange type, and routing-key publishing for normal Laravel queue jobs.
• Queue argument support for lazy queues, priority queues, quorum queues, delayed priority, and failed-message rerouting.
• Optional Laravel Horizon integration via RABBITMQ_WORKER=horizon.
• Horizon events for pending, pushed, reserved, deleted, and failed jobs.
• Optional Laravel Octane AMQP pool reset via RABBITMQ_OCTANE_RESET_ON_REQUEST=true.
• Optional high-performance basic_consume worker mode via:
  • RABBITMQ_CONSUME_MODE=consume
  • php artisan rabbitmq:consume --consume-mode=consume
• RabbitMQ admin commands:
  • rabbitmq:exchange-declare
  • rabbitmq:queue-declare
  • rabbitmq:queue-purge
  • rabbitmq:queue-delete
• New README documentation for production configuration, Horizon, Octane, consume mode, queue topology, and admin commands.

Changed

• ext-pcntl is now optional and only suggested. It is required only when running rabbitmq:consume --num-processes greater than 1.
• rabbitmq:consume --consumer-tag now accepts a value instead of behaving like a boolean flag.
• Connection retry backoff is now scoped per connection attempt and no longer permanently increases delay for later connections.
• CI test workflow no longer runs static analysis; it keeps formatting and PHPUnit/RabbitMQ tests.

Fixed

• Published rabbitmq.php config is now correctly merged and used.
• Cached AMQP channels are released after passive queue declaration misses, because RabbitMQ closes the channel on 404 responses.
• Safer queue existence and queue size handling after missing queue checks.

Compatibility

• Defaults remain backward compatible:
  • default exchange remains ''
  • polling remains the default consume mode
  • Horizon and Octane integrations are inactive unless configured and installed

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.2.1...1.3.0

What's Changed

• Fix published RabbitMQ config usage by @iamfarhad in https://github.com/iamfarhad/LaravelRabbitMQ/pull/13

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.2.0...1.2.1

What's Changed

• fix: repair GitHub Actions test workflow by @iamfarhad in https://github.com/iamfarhad/LaravelRabbitMQ/pull/10
• fix: address open issue compatibility bugs by @iamfarhad in https://github.com/iamfarhad/LaravelRabbitMQ/pull/11

New Contributors

• @iamfarhad made their first contribution in https://github.com/iamfarhad/LaravelRabbitMQ/pull/10

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.1.0...1.2.0

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.0.2...1.1.0

[1.1.0] - 2025-01-27

🚀 Major Advanced Features Added

Dead Letter Exchange (DLX)

• Automatic DLX Setup: Easy configuration for failed message handling
• Configurable TTL: Message time-to-live settings
• Dead Letter Queues: Automatic creation of DLQ for each queue
• Routing Key Control: Custom routing for dead-lettered messages
• DLX Integration: Seamless integration with existing queues

Advanced Routing System

• ExchangeManager: Comprehensive exchange management and routing
• Topic Exchanges: Pattern-based message routing (e.g., user.*.email)
• Fanout Exchanges: Broadcast messages to all bound queues
• Headers Exchanges: Route based on message headers
• Exchange Bindings: Flexible queue-to-exchange bindings

Multi-Queue & Multi-Exchange Support

• Queue Configuration: Define multiple queues with different settings
• Exchange Configuration: Configure multiple exchanges with various types
• Lazy Queues: Optimize memory for high-volume queues
• Priority Queues: Support for message and consumer priorities
• Custom Arguments: Full control over queue and exchange arguments

Exponential Backoff Strategy

• ExponentialBackoff: Intelligent retry mechanism with configurable parameters
• Jitter Support: Prevents thundering herd problem with randomized delays
• Configurable Multiplier: Customizable backoff progression
• Max Delay Cap: Prevents excessive wait times
• Execute Helper: Convenient wrapper for retry logic

RPC (Remote Procedure Call)

• RpcClient: Synchronous request-response pattern
• RpcServer: Handle RPC requests with callbacks
• Correlation ID: Automatic request-response matching
• Timeout Control: Configurable timeout for RPC calls
• Reply Queue: Automatic callback queue management

Publisher Confirms

• Reliable Delivery: Broker acknowledgment for published messages
• Confirm Mode: Enable/disable publisher confirms
• Wait for Confirms: Block until messages are confirmed
• Pending Tracking: Track unconfirmed messages
• Timeout Control: Configurable confirmation timeout

Transaction Management

• AMQP Transactions: Full transaction support
• Atomic Operations: Commit/rollback for multiple operations
• Transaction Helper: Convenient transaction wrapper
• Nested Transaction Prevention: Safety checks for transaction state
• Error Handling: Automatic rollback on exceptions

Delayed Messages

• TTL-Based Delay: Built-in delay using message TTL
• Plugin Support: RabbitMQ delayed message exchange plugin
• Flexible Scheduling: Schedule messages for future delivery
• Header-Based Delay: x-delay header support
• Configurable Exchange: Custom delayed exchange names

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.0.1...1.0.2

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/1.0.0...1.0.1

What's Changed

• Update phpstan/phpstan requirement from ^1.10 to ^1.10 || ^2.0 by @dependabot[bot] in https://github.com/iamfarhad/LaravelRabbitMQ/pull/7

New Contributors

• @dependabot[bot] made their first contribution in https://github.com/iamfarhad/LaravelRabbitMQ/pull/7

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.1.2...1.0.0

What's Changed

• feat: make isSecure flag configurable by @algins in https://github.com/iamfarhad/LaravelRabbitMQ/pull/6

New Contributors

• @algins made their first contribution in https://github.com/iamfarhad/LaravelRabbitMQ/pull/6

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.1.1...v0.1.2

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.1.0...v0.1.1

Added

• Made RabbitMQ basic_qos settings (prefetch_size, prefetch_count, global) configurable via the queue.php or RabbitMQConnectionConfig.php configuration file.

Changed

• Updated documentation to reflect the new basic_qos configuration options.

Fixed

• N/A

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.14...v0.1.0

• added laravel 12 support
• fix some issues

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.13...v0.0.14

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.12...v0.0.13

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.11...v0.0.12

-- add parallel consume

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.10...v0.0.11

• add support for laravel 10

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.9...v0.0.10

• Added some test

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.8...v0.0.9

• Fix critical bug in composer

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.7...v0.0.8

Fix critical bug in declare queues

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.6...v0.0.7

Fixe bug

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.5...v0.0.6

Fix issue #issue-1515688142

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.4...v0.0.5

• Add Rector

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.3...v0.0.4

Important

• fix consumer bug

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.2...v0.0.3

update readme

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/compare/v0.0.1...v0.0.2

fix some bugs

Full Changelog: https://github.com/iamfarhad/LaravelRabbitMQ/commits/v0.0.1

release first version