使用jmsTemboard（Spring JMS）重复调度ActiveMQ的消息传递

Question

我正在以以下方式向队列发送消息：

我想安排重复我的信息。我的意思是，无论控制器（如下所示）中的this linejsmClient.send（标识符）；正在发送什么消息，我都想继续发送，比如说10次或100次（取决于我设置的计时器）。我的消费者（以下未显示）将继续消费相同的消息，直到我要求它停止。例如，即使我的生产者将发送消息10或100次，如果我想在第5次（生产者发送消息10次）或第50次（生产者发送消息100次）停止接收消息，我应该能做到。

由于我使用的是JMS 2和ActiveMQ（版本5.15.8），所以我无法找出以下内容：

Delay and Schedule Message Delivery（延迟和计划消息传递）文档在以下部分中讨论了AMQ_SCHEDULED_REPEAT（重复）：

MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage("test msg");
long delay = 30 * 1000;
long period = 10 * 1000;
int repeat = 9;
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay);
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, period);
message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, repeat);
producer.send(message);

如果我理解正确的话，上面的代码考虑的不是JMS 2，而是JMS 1.1？我想知道我需要在下面的代码中做些什么更改，以便我可以执行类似于消息的操作。setIntProperty（ScheduledMessage.AMQ_SCHEDULED_REPEAT，REPEAT） 。在Spring文档中，我找不到很多关于计划重复的有用信息。

我的JmsProducer课程：

@Component
public class JmsProducer {
    @Autowired
    JmsTemplate jmsTemplate;

    @Value("${jms.queue.destination}")
    String destinationQueue;

    public void send(String msg){
        jmsTemplate.convertAndSend(destinationQueue, msg);
    }
}

JmsClient接口：

public interface JmsClient {
    public void send(String msg);

}

JmsClientImpl类：

@Service
public class JmsClientImpl implements JmsClient{


    @Autowired
    JmsProducer jmsProducer;

    @Override
    public void send(String msg) {
        jmsProducer.send(msg);
    }


}

在我的REST控制器中，我正在发送这样的消息：

try {

            DataRetrieverDao dataRetrieverDao = (DataRetrieverDao) context.getBean("dataRetrieverDao");
            String identifier=dataRetrieverDao.sendDownloadInfo(user_id);
            logger.info("VALUE OF STRING: "+identifier);
            jsmClient.send(identifier);



        }

基于我的研究：

在这个stackoverflow线程中，activemq包不支持JMS 2.0，所以我应该切换到artemis吗？但是，我在jmsTemplate方面提出的问题仍然在我的脑海中。请告诉我在这种情况下最好的做法是什么。谢谢




Answer 1

被耽搁的路

延迟了

正如您所注意到的，ActiveMQ 5。x不支持JMS 2.0，所以如果您想要JMS 2.0支持，您需要切换到ActiveMQ Artemis。然而，ActiveMQ Artemis不支持延迟