public void registerObserver()

in modules/core/src/main/java/org/apache/fluo/recipes/core/combine/CombineQueue.java [53:73]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public void registerObserver(Registry obsRegistry, Combiner<K, V> combiner,
      ChangeObserver<K, V> updateObserver);

  /**
   * Get a combiner queue instance.
   * 
   * @param combineQueueId This should be the same id passed to {@link #configure(String)} before
   *        initializing Fluo.
   * @param appConfig Application configuration obtained from
   *        {@code FluoClient.getAppConfiguration()},
   *        {@code FluoConfiguration.getAppConfiguration()}, or
   *        {@code ObserverProvider.Context.getAppConfiguration()}
   */
  public static <K2, V2> CombineQueue<K2, V2> getInstance(String combineQueueId,
      SimpleConfiguration appConfig) {
    try {
      return new CombineQueueImpl<>(combineQueueId, appConfig);
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }