public void registerObserver()

in modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java [247:261]

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

  public void registerObserver(ObserverProvider.Registry obsRegistry,
      org.apache.fluo.recipes.core.export.function.Exporter<K, V> exporter) {
    Preconditions.checkState(opts.exporterType == null,
        "Expected exporter type not be set, it was set to %s.  Cannot not use the old and new way of configuring "
            + "exporters at the same time.",
        opts.exporterType);
    Observer obs;
    try {
      obs = new ExportObserverImpl<K, V>(queueId, opts, serializer, exporter);
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
    obsRegistry.forColumn(ExportBucket.newNotificationColumn(queueId), NotificationType.WEAK)
        .withId("exportq-" + queueId).useObserver(obs);
  }