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