да, на самом деле это можно сделать двумя способами:
a) вы можете сделать это, удалив / повторно добавив получателя / потребителя, что поддерживается нашим API EPL.Для очереди, которая будет иметь семантику, идентичную упомянутой выше концепции остановки / запуска, тогда как для темы вы пропустите сообщения, отправленные в период между остановкой и перезапуском.
b) использовать функцию управления потоком в приемнике http://www.apamacommunity.com/documents/10.3.0.1/apama_10.3.0.1_webhelp/apama-webhelp/index.html#page/apama-webhelp%2Fco-DepAndManApaApp_receiver_flow_control.html, которая может дать вам более эффективный способ ее решения, если целью является управление потоком, то есть уменьшение или приостановка приема, если по какой-либо причине (слишкомвыполняется много операций, произошел сбой какого-либо нижестоящего компонента или базы данных, необходимых для выполнения) в настоящее время вы не готовы обрабатывать больше входящих сообщений.Как уже упоминалось в этом документе, есть пример, который показывает, как это сделать в EPL, так что начать его будет действительно легко.