Can not set 'x-message-ttl' in arguments in queue_options about rabbitmqbundle HOT 13 CLOSED

work around ( hack ) was to add an additional parameter for the message properties and use the AMQP expiration setting. So in the producer I added this

• https://github.com/videlalvaro/RabbitMqBundle/blob/master/RabbitMq/Producer.php

Original:

public function publish($msgBody, $routingKey = '')
{
$this->setupProducer();

    $msg = new AMQPMessage($msgBody, array('content_type' => 'text/plain', 'delivery_mode' => 2));
    $this->ch->basic_publish($msg, $this->exchangeOptions['name'], $routingKey);
}

Hack:

public function publish($msgBody, $routingKey = '', $msgProperties = array())
{
$this->setupProducer();

    $msg = new AMQPMessage($msgBody, array_merge(array('content_type' => 'text/plain', 'delivery_mode' => 2), $msgProperties));
    $this->ch->basic_publish($msg, $this->exchangeOptions['name'], $routingKey);
}

Then call like this:

$this->exchangeProducer->publish(json_encode($message),'', array('expiration' => '3600000'));

from rabbitmqbundle.

Right syntax, which works for me:

queue_options: {name: 'upload-picture', arguments: {'x-message-ttl': ['I', 3600000]}}

from rabbitmqbundle.

@slot can you point me to the documentation on this? I thought I had tried that syntax but maybe I had an error

from rabbitmqbundle.

Well as I said, it works for me. It's not properly documented but the example points you in the right direction:

queue_options: {name: 'upload-picture', arguments: {'x-ha-policy': ['S', 'all']}}

where 'S' is the datatype of the argument value.

Argument data is being type-checked and processed in \PhpAmqpLib\Wire\AMQPWriter in the write_table() method.

from rabbitmqbundle.

Would any of you mind documenting this in the README?

from rabbitmqbundle.

I will do it.

from rabbitmqbundle.

Done, in https://github.com/videlalvaro/RabbitMqBundle/pull/109

from rabbitmqbundle.

@slot The suggested syntax works on the queue level, I'm looking to add the x-message-ttl on the message level. So not all messages in the queue will have a expiration. The added documentation was needed but the suggested syntax does not work on a message level expiration but does for the queue.

Looking to implement the message options AMQP provides but with RabbitMQ

https://github.com/videlalvaro/php-amqplib/blob/master/PhpAmqpLib/Message/AMQPMessage.php

from rabbitmqbundle.

+1 for allowing to set a pet-ttl message, if it is supported by the protocol. The proposed hack is basically a 2-liner...

from rabbitmqbundle.

I'm seeing this issue. Is there a fix for this, 7 years later?

The problem is that the value is set, however, It's being stored as a string.

I'm using Rabbitmq 3.7.5, Erlang 20.1.7

from rabbitmqbundle.

Nevermind, it seems to work even though the rabbitmq web console displays the value as a string.

from rabbitmqbundle.

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. Thank you for your contributions.

from rabbitmqbundle.

Already possible using $additionalProperties.

from rabbitmqbundle.