Queue pool

Last updated:
Edit on GitHub

Queue pool is designed to allow P&S (Publish and Synchronization) messages to be sent to several queues.

Configuration

Queue pools are defined with unique names in config/Shared/stores.php

<?php
...
    'currencyIsoCodes' => ['EUR', 'CHF'],
    'queuePools' => [
        'synchronizationPool' => [
            'AT-connection',
            'DE-connection',
        ],
        'fooPool' => [
            'DE-connection',
            'US-connection',
        ]
    ],
    'storesWithSharedPersistence' => ['AT'],
];
...

Sending messages

Messages must be prepared for sending to queue pools. You can do it by setting the QueuePool property for the QueueSendMessageTransfer.

<?php
...
$queueSendTransfer = new QueueSendMessageTransfer();
    $queueSendTransfer->setQueuePoolName('fooPool');

    $queueClient->sendMessage('mail', $queueSendTransfer);
...

In this example, the message is configured to be sent to mail queue in DE and US store queues.