docs: public void stop() {
          /*
           * Sets the shutdown flag. Future sends to the batcher are not accepted.
           * The processors wait for the current messages in the queue and with
           * the processor or collector to complete
           */
          isShutDown = true;
          
          int waitTimeinMillis = CONFIGURATION.getBatcherWaitTimeBeforeShutdown(this.name);
          long timeToWait = waitTimeinMillis + System.currentTimeMillis();
          while ((queue.size() > 0 || batch.size() > 0)
                  && (System.currentTimeMillis() < timeToWait)) {
              try {
                  Thread.sleep(1000);
              } catch (InterruptedException e) {
                  break;
              }
          }
          try {
              shouldCollectorShutdown = true;
              processor.shutdownNow();
              /*
               * processor.awaitTermination(10000, TimeUnit.SECONDS); if
               * (!processor.isShutdown()) { processor.shutdownNow(); }
               */
          } catch (Throwable e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
          }
      }