1

我有一个关于ActiveMQ和关于消息生命周期的AJAX接口的问题。在 AMQ Web 界面中,我可以为消息设置TimeToLive值(以毫秒为单位)。我已经发现,我可以通过 REST 使用这个参数:

curl -vd  body="test" "http://localhost:8161/demo/message/TESTQUEUE?type=queue&JMSTimeToLive=500&JMSPersistent=-1"

此示例消息将持续 500 毫秒

但是如何使用 AMQ Ajax 接口来设置这些参数呢?发送消息的 JavaScript 函数只提供两个参数

amq.sendMessage(myDestination,myMessage);

信息:http ://activemq.apache.org/ajax.html

不幸的是,myDestination 不是 URL,它类似于“queue://”

谢谢四位的帮助

问候罗尔夫

4

1 回答 1

0

AJAX 客户端的当前实现不提供发送带有生存时间的消息的可能性。

消息离开的时间基本上是在消息属性(标题)中设置的,通过属性“JMSExpiration”当前如果你通过amq.js 代码,你会看到没有允许你定义标题或时间的 API为了活着。

将此功能添加到客户端应该相对容易。检查代码,您可能只是为您的应用程序硬编码 TTL。最后,它只是执行一个 post 命令,就像您执行 REST 调用一样。

于 2013-03-19T10:11:02.543 回答