code: @Override
      public void process(WatchedEvent event) {
          Watcher.Event.KeeperState state = event.getState();
          try {
              switch (state) {
              case Expired: {
                  _reconnect();
                  break;
              }
              case SyncConnected: {
                  _eventNodeChanged(event);
                  break;
              }
              default: {
                  LOGGER.debug(event.toString());
              }
              }
          } catch (Exception e) {
              LOGGER.warn(e.getMessage(), e);
          }
      }
docs: {@inheritDoc}