search

rabbitmq / rabbitmq-delayed-message-exchange

Delayed Messaging for RabbitMQ
Other
2.02k stars 149 forks source link

X-delay header doesn't negate the value. #64

Open manish7-thakur opened 8 years ago

manish7-thakur commented 8 years ago

As mentioned on the link https://www.rabbitmq.com/blog/2015/04/16/scheduling-messages-with-rabbitmq/

The plugin doesn't negate the value of delay provided in the header. The POC I did still shows the same positive value. delayed-consumer processed message Hello World 1 at {x-delay=10000}

comensee commented 7 years ago

up

espenekvang commented 7 years ago

We have the same issue

AndreTheHunter commented 3 years ago

I'm having the same issue. I'm using the JMS https://www.rabbitmq.com/jms-client.html and it shows the value of x-delay as positive, but when I fetch the messages on the RabbitMQ admin, it shows correctly.

alex-3pi commented 2 years ago

I found out that publishing through admin with header x-delay=10000 will return correct msg with x-delay=-10000, but publishing with node.js amqplib, same message will return x-delay with positive value, after correct amount of time. 

const options = { 'headers': { 'x-delay': 10000, 'x-other-type': 'some other type'}};
channel.publish(exchange, key, Buffer.from(msg), options);
bruse-peng commented 2 years ago

how to use with the python lib of pika