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 hc130怎么读写内部flash存储信息
  • ¥15 Axure rp9注册与登录交互
  • ¥15 我下载图形界面重启完就变成这样了,打字也打不了,动也动不了,该怎么解决(操作系统-centos)
  • ¥15 VBA中在窗体中遍历所有checkbox控件,提取出被选中的checkbox的caption值
  • ¥15 在Ubuntu上有什么命令,或者是系统文件能告诉我链接nvme ssd的pcie槽位是不是支持热插拔功能?
  • ¥15 ansys license许可证问题
  • ¥20 QQ号和密码都能正常登录微信 QQ号和密码登录微信显示密码错误
  • ¥15 qiankun主应用注册子应用提示跨域
  • ¥15 单片机RTOS Kernel与应用分离开发,Kernel如何调起应用?
  • ¥15 快手小店商家版APP怎么第三方APP跳转到指定用户聊天界面