@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);
        }
    }
@ 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 ) ; } }
Closes consumers of this {@link SourceTableRowProcessingPublisher}.
Usually this will be done automatically when
{@link #runRowProcessing(Queue, TaskListener)} is invoked.