search

php-enqueue / enqueue-dev

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro
https://enqueue.forma-pro.com/
MIT License
2.17k stars 429 forks source link

DBAL Message handler does not set messageID #1319

Open fperrony opened 10 months ago

fperrony commented 10 months ago

The DBAL Message handler does not set messageID when add by method setMessageId

Set

 $message->setMessageId('myId));

DbalProducer->send()...

    $dbalMessage = [
        'id' => Uuid::uuid4(),

Don't set id on database vield. Always create new

On Consume

$dbalContext->convertMessage(array $arrayMessage)

On convert, get id from database and set in headet changing de header

 public function setMessageId(string $messageId = null): void
{
    $this->setHeader('message_id', $messageId);
}

Thanks