c# - 使用 ActiveMQ 5.3 和 NMS 延迟交付

Question

我正在尝试使用 NMS 的新延迟交付功能。

schedulerSupport 属性已在配置文件中设置，我正在使用以下代码尝试延迟消息的传递，直到达到用户选择的日期/时间。

代码(目前似乎无法运行)如下:

var timeDelay = dateTimePicker.Value.Subtract(DateTime.Now).TotalMilliseconds;     
var message = topicPublisher.CreateTextMessage();
message.Properties["AMQ_SCHEDULED_DELAY"] = timeDelay;
message.Text = CM.ToXMLString();

topicPublisher.Send(message);

你能指出这个例子中可能不正确的地方吗？

非常感谢!

Answer 1

我没有从提供的代码中看到任何明显的东西。

您可以尝试在代理中打开日志记录以查看调度程序是否收到消息以及值是否正确，这也将确认您确实启用了调度程序支持。您也可以尝试创建一个小型 Java 程序来执行类似的操作以确定 NMS 客户端是否正常运行。

我假设您有一个消费者正在运行并且它的连接对象已经启动？

问候蒂姆。

www.fusesource.com