Как установить частоту производителя ActiveMQ CMS

У меня есть производитель CMS, который отправляет сообщение в цикле while. Это очень быстро и не нужно. Я хотел бы ограничить это 1 сообщение в секунду или около того.Как установить частоту производителя ActiveMQ CMS

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 функция или способ установить частоту отправки?

источник

2015-09-24 Anonymous

Замедлить производителя? Это не проблема из ActiveMQ, а проблема от той, которая использует activeMQ. –

Что вы подразумеваете под «медленным продюсером»? Я не хочу вводить сон или такой хак, я спрашиваю, есть ли в библиотеке средство для таких целей. Плюс, этот пример я взял с официального сайта ActiveMQ. Это не мое производство, для вашей информации. –

В ActiveMQ-CPP такого объекта нет. Контроль скорости отправки производителем - это то, что нужно обработать вашим приложением, клиент C++ отвечает только за отправку сообщений, вы несете ответственность за логику, связанную с тем, что и когда отправляется сообщение.

источник

2015-09-24 10:06:33

Итак, пользователь должен таймеру. Благодарю. –

Как установить частоту производителя ActiveMQ CMS

ответ

Смежные вопросы