code: private void init() {
          assertUnlocked();
          
          lock.lock();
          try {
              httpSender.init(cfg);
  
              LOG.info(
                  "Starting with "
                      + DEFAULT_REQ_PROC_COUNT + " request processors");
  
              procThreads = new RequestProcessor[DEFAULT_REQ_PROC_COUNT];
  
              for (int i = 0; i < procThreads.length; i++) {
                  procThreads[i] = new RequestProcessor(i);
                  procThreads[i].start();
              }
  
          } finally {
              lock.unlock();
          }
      }
docs: Initialize the session.  This initializes the underlying HTTP
  transport implementation and starts the receive thread.