docs: @Override
      public void run() {
          while(!stop) {
              try {
                  EventModel<?> event = events.take();
                  processEvent(event);
              } catch (InterruptedException e) {
                  log.warn("interrupted", e);
              }
          }
      }