activemq - 如何设置 ActiveMQ CMS 生产者频率

Question

我有一个 CMS 生产者，它在 while 循环中发送消息。这是非常快速且不必要的。我想将此限制为每秒 1 条左右的消息。

BytesMessage *message = session->createBytesMessage();
message->setStringProperty("M_P_C_N","someMsg");
message->setStringProperty("M_P_T_N","someTopic");
message->writeBytes(data);
producer->send(message);    

我想知道CMS是否具有设置发送频率的功能或方法？

Answer 1

ActiveMQ-CPP 中没有这样的工具。控制生产者发送速率是您的应用程序需要处理的事情，C++ 客户端只负责发送消息，您负责围绕发送消息的内容和时间的逻辑。