code: public void closeConsumers() {
          final List<RowProcessingConsumer> configurableConsumers = getConfigurableConsumers();
          final TaskRunner taskRunner = _publishers.getTaskRunner();
          for (RowProcessingConsumer consumer : configurableConsumers) {
              TaskRunnable task = createCloseTask(consumer, null);
              taskRunner.run(task);
          }
      }
docs: Closes consumers of this {@link RowProcessingPublisher}. Usually this
  will be done automatically when
  {@link #runRowProcessing(Queue, TaskListener)} is invoked.