douyou2234 2016-07-25 20:25
浏览 190
已采纳

如何从队列中只读取一次消息

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();
  • 写回答

1条回答 默认 最新

  • doxrxwn2252 2016-07-26 15:19
    关注

    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

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?