如何设置 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++ 客户端仅负责发送消息，您负责围绕消息发送内容和发送时间的逻辑。