spryker/rabbit-mq

Included commits: 2.24.0...2.25.0

Improvements

• Performance improvement: optimized message processing so the worker now reads the batch size of messages and stops immediately when the batch is completed, instead of waiting for the timeout.

Included commits: 2.23.1...2.24.0

Fixes

• Adjusted Connection::__destruct() to skip AMQPConnectionClosedException if the connection is already closed.

Included commits: 2.23.0...2.23.1

Fixes

• Fixed a factory issue.

Included commits: 2.22.0...2.23.0

Improvements

• Added RabbitMqFacade::getQueues() to get all the queues with one request for queue worker performance optimization.
• Adjusted RabbitMqQueueMessageCheckerPlugin to implement QueueBulkMessageCheckerPluginInterface for queue worker performance optimization.
• Deprecated RabbitMqQueueTransfer , use QueueInformationTransfer instead.
• Deprecated RabbitMqQueueCollectionTransfer , use QueueInformationCollectionTransfer instead.

Checklist

• I agree with the Code Contribution License Agreement in CONTRIBUTING.md

Included commits: 2.21.0...2.22.0

Improvements

• Introduced RabbitMqQueueMetricsExpanderPlugin plugin for getting rabbit-mq queues metrics.
• Introduced QueueMetricsRequest.queueName transfer field.
• Introduced QueueMetricsRequest.storeName transfer field.
• Introduced QueueMetricsRequest.localeName transfer field.
• Introduced QueueMetricsResponse.messageCount transfer field.
• Introduced QueueMetricsResponse.consumerCount transfer field.

Included commits: 2.21.0...2.21.1

Improvements

• Added phpstan/phpstan new ^2.* module version support.
• Adjusted RabbitMqFacade::getQueueMetrics() so it does not perform redundant filtration and directly returns AMQPChannel[].

Included commits: 2.20.0...2.21.0

Fixes

• Adjusted RabbitMqClient::createQueueAdapter() so it publishes messages to the correct instance instead of broadcasting to all instances.

Included commits: 2.19.0...2.20.0

Improvements

• Introduced RabbitMqQueueMessageCheckerPlugin to check if there are messages in queues for RabbitMQ.
• Introduced RabbitMqFacade::areQueuesEmpty() to go through queues and see if at least one has messages.

Included commits: 2.18.0...2.19.0

Improvements

• Introduced \Spryker\Client\RabbitMq\RabbitMqConfig::getHeartBeat() config method.
• Introduced RABBITMQ:RABBITMQ_HEART_BEAT_SECONDS environment config.
• Adjusted \Spryker\Client\RabbitMq\RabbitMqClient::getConnection() client method to check and use working connections from the cache if exists.
• Increased Store module version dependency.
• Increased Testify module version dependency.

Checklist

• I agree with the Code Contribution License Agreement in CONTRIBUTING.md

Included commits: 2.17.0...2.18.0

Improvements

• Adjusted RabbitMqHelper in order to put a client with all required mocks into the LocatorCache.