code: @Override
      public void setOutputInvoker(final OutputInvoker outputInvoker) {
          this.outputInvoker = outputInvoker;
  
          if (concurrency > 1)
              outputInvoker.setOutputConcurrency(concurrency);
      }
docs: /*
  (non-Javadoc)
  
  @see com.nokia.dempsy.output.OutputExecuter#setOutputInvoker(com.nokia.dempsy.output.OutputInvoker)