Search code examples
phpactivemq-classicstompphp-5.5

How to read a message only once from a queue


I am using ActiveMQ to store a queue of messages.
I am using the PECL Stomp extension to connect to it. I am publishing to the queue successfully, and reading from it successfuly.
How do I configure the queue to delete a message after I consumed it?
In my listener, I use

$c = new Stomp($url);
$c->subscribe('/queue/something');
echo $c->readFrame();

Solution

  • You have to acknowledge the consumption of a message to get them "deleted" from the queue. You can do that with $stomp->ack($messageID).

    If you don't want to explicitely acknowledge the receipt, you can set the headers of $stomp->subscribe of ack to auto. This will make the server auto acknowledge the message and assume it was correctly delivered.

    $stomp->subscribe('/queue/something', array('ack' => 'auto'));
    

    References:
    http://php.net/manual/en/stomp.ack.php
    http://php.net/manual/en/stomp.subscribe.php
    https://stomp.github.io/stomp-specification-1.1.html#SUBSCRIBE