public void process()

in twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/RewatchOnExpireWatcher.java [69:92]

• 23 lines of code
• 8 McCabe index (conditional complexity)

  public void process(WatchedEvent event) {
    if (delegate != null && event.getType() != Event.EventType.None) {
      try {
        delegate.process(event);
      } catch (Throwable t) {
        LOG.error("Watcher throws exception.", t);
      }
    }

    if (event.getState() != Event.KeeperState.Expired) {
      return;
    }
    switch (actionType) {
      case EXISTS:
        exists();
        break;
      case CHILDREN:
        children();
        break;
      case DATA:
        data();
        break;
    }
  }