Add a header when sending a message with php-enqueue and RabbitMQ

Question

I am trying to send a header using php-enqueue bundle I'm trying this:

public function __construct(
    ProducerInterface    $producer
)
{
    parent::__construct();

    $this->producer = $producer;
}

//... Inside function...
$m = new Message(
   'message to send',
    [],
    [
       'm' => 1
    ]
);

$this->producer->sendCommand('newMessageFromApi', $m);

But the header does not reach the consumer. These are the only headers that arrive.

[
      "content_type" => "text/plain",
      "delivery_mode" => 2,
      "message_id" => "38f96af0-64de-4a31-9315-6b51dd5f8baf",
      "timestamp" => 1652027271
]

See "You can choose how to send messages either using a transport directly or with the client" php-enqueue.github.io/bundle/message_producer — Max
– Max, Commented Oct 13, 2022 at 8:06

JayJay · Accepted Answer · 2022-05-17 12:28:26Z

0

Try this

$m = new Message('message to send',['m' => 1]);

answered May 17, 2022 at 12:28

JayJay

1

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Add a header when sending a message with php-enqueue and RabbitMQ

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related