0

我编写了一个简单的ActiveMQ客户端程序来生成如下消息：

public static void main(String[] args) throws Throwable
{
    final ActiveMQConnectionFactory conFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    final QueueConnection connection = conFactory.createQueueConnection();
    final Session session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    final Destination destination = new ActiveMQQueue("MJ_SAF");
    final MessageProducer producer = session.createProducer(destination);

    Message message = session.createTextMessage("test");
    message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 20);
    message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, 1);
    message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, 1);
    producer.send(message);
}

当这个程序执行时，我希望在预定部分存储一条消息，ActiveMQ并在 20 秒后发送MJ_SAF队列，但是当我连接到 web consol 时看到以下结果：

在此处输入图像描述

存储了两条消息，MJ_SAF这是不正确的，但是当我通常发送消息（没有调度）时，我在 Web 控制台中看到一条消息。

public static void main(String[] args) throws Throwable
{
    final ActiveMQConnectionFactory conFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    final QueueConnection connection = conFactory.createQueueConnection();
    final Session session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    final Destination destination = new ActiveMQQueue("MJ_SAF");
    final MessageProducer producer = session.createProducer(destination);

    Message message = session.createTextMessage("test");
    producer.send(message);
}

通过上面的代码，一切都很好：

在此处输入图像描述

我不明白这种行为。有谁知道这其中的原因？

4

1 回答 1

4

您将属性ScheduledMessage.AMQ_SCHEDULED_REPEAT设置为 1，因此它将重复 1 次，总共给您 2 条消息。

有关属性的说明，请参见此处。据我了解，您当前的设置将等待 20 毫秒，发布 1 条消息，等待 1 毫秒，然后发布第二条消息，然后结束。

于 2013-02-18T11:26:58.090 回答