diff options
Diffstat (limited to 'v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java')
-rw-r--r-- | v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java b/v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java index 54acce3f2..8a0dead0e 100644 --- a/v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java +++ b/v3po/impl/src/main/java/io/fd/honeycomb/v3po/impl/V3poProvider.java @@ -21,6 +21,7 @@ import com.google.common.collect.Lists; import com.google.common.util.concurrent.CheckedFuture; import com.google.common.util.concurrent.Futures; import io.fd.honeycomb.v3po.impl.data.VppDataBrokerInitializationProvider; +import io.fd.honeycomb.v3po.impl.data.VppReaderRegistry; import java.io.IOException; import java.util.HashMap; import java.util.List; @@ -187,8 +188,11 @@ public class V3poProvider implements BindingAwareProvider, AutoCloseable { vppPollOperData); startOperationalUpdateTimer(); - // TODO make configurable - vppDataBrokerInitializationProvider = new VppDataBrokerInitializationProvider(db); + final VppReaderRegistry readerRegistry = VppReaderRegistry.getInstance(api); + + // TODO make configurable: + vppDataBrokerInitializationProvider = new VppDataBrokerInitializationProvider(db, readerRegistry); + // TODO pull the registration into Module domBroker.registerProvider(vppDataBrokerInitializationProvider); } |