code: public void run() {
  
          while (!stop) {
              try {
                  //  Poll the sockets inputs
                  pollers.poll();
  
                  //  read the speaking one
                  for (int i=0 ; i<pollers.getSize() ; i++) {
                      if (pollers.pollin(i)) {
                          manageInputBuffer(i);
                      }
                  }
              }
              catch (Error | Exception e) {
                  e.printStackTrace();
              }
          }
          ApiUtil.printTrace("------------ End of ZmqMainThread ---------------");
      }
docs: ===============================================================