docs: public void exhaust(Long pipelineId) {
          Assert.notNull(pipelineId);
          TerminMonitor terminMonitor = ArbitrateFactory.getInstance(pipelineId, TerminMonitor.class);
          int size = terminMonitor.size();
          try {
              for (int i = 0; i < size; i++) {
                  Long processId;
                  processId = terminMonitor.waitForProcess();
                  TerminEventData data = new TerminEventData();
                  data.setPipelineId(pipelineId);
                  data.setProcessId(processId);
                  ack(data);
              }
          } catch (InterruptedException e) {
              throw new ArbitrateException(e);
          }
      }