docs: @Override
      public void subscribe(String channel, ISubscriber<ID, DATA> subscriber) {
          try {
              cursors.get(channel).subscribe(subscriber);
          } catch (ExecutionException e) {
              LOGGER.error(e.getMessage(), e);
          }
      }