docs: @Override
      public boolean publish(String channel, IMessage<ID, DATA> msg) {
          try {
              return cursors.get(channel).publish(msg);
          } catch (ExecutionException e) {
              LOGGER.error(e.getMessage(), e);
              return false;
          }
      }