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

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

报告相同问题?

悬赏问题

  • ¥20 求数据集和代码#有偿答复
  • ¥15 关于下拉菜单选项关联的问题
  • ¥20 java-OJ-健康体检
  • ¥15 rs485的上拉下拉,不会对a-b<-200mv有影响吗,就是接受时,对判断逻辑0有影响吗
  • ¥15 使用phpstudy在云服务器上搭建个人网站
  • ¥15 应该如何判断含间隙的曲柄摇杆机构,轴与轴承是否发生了碰撞?
  • ¥15 vue3+express部署到nginx
  • ¥20 搭建pt1000三线制高精度测温电路
  • ¥15 使用Jdk8自带的算法,和Jdk11自带的加密结果会一样吗,不一样的话有什么解决方案,Jdk不能升级的情况
  • ¥15 画两个图 python或R