ActiveMQ JobScheduler 删除消息

Question

是否可以通过 Stomp 从 PHP 订阅 ActiveMQ 代理并访问 JobScheduler（然后通过其 jobId 删除预定消息）？

我有一组计划消息，用于从 2 个 Web 服务器生成的队列“PROD”，并且在同一 Web 服务器上发生事件时（知道 jobIds），我想将它们从 JobScheduler 中删除，以便消费者（用 Java 编写并位于多个远程服务器上）没有收到它们。

我正在使用 ActiveMQ 代理 v5.9.1，并使用 Stomp 连接到 PHP 形式的代理。

Answer 1

您可以通过 STOMP 在 ActiveMQ 中管理计划作业。我已经written about this before 展示了如何使用 ActiveMQ Java 客户端进行操作，但原理是相同的。您可以发送设置了特定标头的消息，这些标头将对预定的消息进行操作。

要删除使用 Java 客户端安排的消息，您需要执行以下操作：

    Message remove = session.createMessage();
    remove.setStringProperty(ScheduledMessage.AMQ_SCHEDULER_ACTION,
            ScheduledMessage.AMQ_SCHEDULER_ACTION_REMOVE);
    remove.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_ID,
            scheduled.getStringProperty(ScheduledMessage.AMQ_SCHEDULED_ID));
    producer.send(remove);

在使用调度程序时可以使用的完整消息属性值集记录在here 中，在 STOMP 中只需使用每个字符串文字作为消息属性。