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();
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