Laravel Rabbitmq Laravel Package

Legacy Features

• Basic RabbitMQ queue driver functionality
• Connection pooling system
• Channel management
• Basic consumer commands
• Standard Laravel Queue API integration

🚀 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

🔧 Configuration Enhancements

New Configuration Sections

'backoff' => [
    'enabled' => true,
    'base_delay' => 1000,
    'max_delay' => 60000,
    'multiplier' => 2.0,
    'jitter' => true,
],

'exchanges' => [
    'default' => [...],
    'notifications' => [...],
    // Custom exchanges
],

'queues' => [
    'default' => [...],
    'high-priority' => [...],
    // Custom queues
],

'dead_letter' => [
    'enabled' => true,
    'exchange' => 'dlx',
    'exchange_type' => 'direct',
    'queue_suffix' => '.dlq',
],

'delayed_message' => [
    'enabled' => false,
    'plugin_enabled' => false,
],

'rpc' => [
    'enabled' => false,
    'timeout' => 30,
],

'publisher_confirms' => [
    'enabled' => false,
    'timeout' => 5,
],

'transactions' => [
    'enabled' => false,
],

New Environment Variables

• RABBITMQ_BACKOFF_ENABLED - Enable exponential backoff
• RABBITMQ_BACKOFF_BASE_DELAY - Base delay in milliseconds
• RABBITMQ_BACKOFF_MAX_DELAY - Maximum delay in milliseconds
• RABBITMQ_BACKOFF_MULTIPLIER - Delay multiplier
• RABBITMQ_BACKOFF_JITTER - Enable jitter
• RABBITMQ_DLX_ENABLED - Enable dead letter exchange
• RABBITMQ_DLX_EXCHANGE - DLX exchange name
• RABBITMQ_DLX_EXCHANGE_TYPE - DLX exchange type
• RABBITMQ_DLX_QUEUE_SUFFIX - DLQ suffix
• RABBITMQ_DLX_TTL - Message TTL in milliseconds
• RABBITMQ_DELAYED_MESSAGE_ENABLED - Enable delayed messages
• RABBITMQ_DELAYED_PLUGIN_ENABLED - Use delayed message plugin
• RABBITMQ_DELAYED_EXCHANGE - Delayed exchange name
• RABBITMQ_RPC_ENABLED - Enable RPC support
• RABBITMQ_RPC_TIMEOUT - RPC timeout in seconds
• RABBITMQ_RPC_CALLBACK_PREFIX - RPC callback queue prefix
• RABBITMQ_PUBLISHER_CONFIRMS_ENABLED - Enable publisher confirms
• RABBITMQ_PUBLISHER_CONFIRMS_TIMEOUT - Publisher confirms timeout
• RABBITMQ_TRANSACTIONS_ENABLED - Enable transactions

🛠️ API Enhancements

New RabbitQueue Methods

// Advanced queue declaration
$queue->declareAdvancedQueue($name, $durable, $autoDelete, $lazy, $priority, $deadLetterConfig);

// Exchange management
$queue->getExchangeManager();
$queue->publishToExchange($exchange, $payload, $routingKey, $headers);

// Backoff and retry
$queue->getBackoff();

// Publisher confirms
$queue->getPublisherConfirms();

// Transactions
$queue->getTransactionManager();
$queue->transaction(callable $callback);

// RPC
$queue->getRpcClient();
$queue->rpcCall($queue, $message, $headers);

// Dead letter exchange
$queue->setupDeadLetterExchange($queueName, $dlxName, $dlxRoutingKey);

// Delayed messages
$queue->publishDelayed($queue, $payload, $delay, $headers);

New Support Classes

• ExchangeManager - Exchange and routing management
• ExponentialBackoff - Retry logic with exponential backoff
• RpcClient - RPC client implementation
• RpcServer - RPC server implementation
• PublisherConfirms - Publisher confirm handling
• TransactionManager - Transaction management

🔄 Breaking Changes

None. All new features are opt-in and backward compatible.

📦 Dependencies

Requirements (Unchanged)

• PHP 8.2+
• Laravel 11.x|12.x
• ext-amqp
• ext-pcntl