есть существующее управление потоком, которое может выполнять агрегацию для входящего N-сообщения (или всего входящего сообщения в течение таймаута).

Question

. Я пытаюсь выполнить объединение N входящих сообщений или всего входящего сообщения в течение таймаута, то он отправит на следующий шаг. (вызов api). Потому что я не хочу слишком часто нажимать на api, поэтому я хочу только отправить агрегатное сообщение.

Есть ли существующее управление потоком, которое я могу использовать, или мне нужно создать пользовательский контроль потока?

Спасибо Ивэнь

Answer 1

Вы можете использовать Scatter-собирать и реф потока для вызова несколько потоков и агрегировать сообщение .. Если вы хотите, некоторые функции, как тайм-аут .. Вы можете использовать весь маршрутизатор (самортизированный) ссылку потока и сборщик-агрегатор для агрегирования сообщений