public static RegisteredObservers load()

in modules/core/src/main/java/org/apache/fluo/core/observer/ObserverUtil.java [62:109]

37 lines of code
3 McCabe index (conditional complexity)


  public static RegisteredObservers load(CuratorFramework curator) throws Exception {
    ObserverStore ov1 = new ObserverStoreV1();
    ObserverStore ov2 = new ObserverStoreV2();

    // try to load observers using old and new config
    RegisteredObservers co = ov1.load(curator);
    if (co == null) {
      co = ov2.load(curator);
    }

    if (co == null) {
      // no observers configured, so return an empty provider
      co = new RegisteredObservers() {
        @Override
        public Observers getObservers(Environment env) {
          return new Observers() {

            @Override
            public void close() {

            }

            @Override
            public void returnObserver(Observer o) {
              throw new UnsupportedOperationException();
            }

            @Override
            public Observer getObserver(Column col) {
              throw new UnsupportedOperationException();
            }

            @Override
            public String getObserverId(Column col) {
              throw new UnsupportedOperationException();
            }
          };
        }

        @Override
        public Set<Column> getObservedColumns(NotificationType nt) {
          return Collections.emptySet();
        }
      };
    }

    return co;
  }