diff options
author | Marek Gradzki <mgradzki@cisco.com> | 2017-06-08 14:49:22 +0200 |
---|---|---|
committer | Marek Gradzki <mgradzki@cisco.com> | 2017-06-08 14:57:19 +0200 |
commit | d500e65e12ce0ceaa59d30283fabde08ee3bffea (patch) | |
tree | 564603246f73cb6886928e967010dcb10d3477c7 /infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java | |
parent | b09fb9d9df8ff2539710aa3fd05e1f9085d7a936 (diff) |
Hide reader and writer registry builders in registry providers.
Only ReaderRegistry and WriterRegistry instances are needed by other components.
Change-Id: Icc026154e80be4ca9424c79754f342e93fda0735
Signed-off-by: Marek Gradzki <mgradzki@cisco.com>
Diffstat (limited to 'infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java')
-rw-r--r-- | infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java b/infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java index 8370da8bb..86a5ff858 100644 --- a/infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java +++ b/infra/minimal-distribution/src/main/java/io/fd/honeycomb/infra/distro/data/oper/ReaderRegistryProvider.java @@ -18,18 +18,23 @@ package io.fd.honeycomb.infra.distro.data.oper; import com.google.inject.Inject; import io.fd.honeycomb.infra.distro.ProviderTrait; -import io.fd.honeycomb.translate.read.registry.ModifiableReaderRegistryBuilder; +import io.fd.honeycomb.translate.impl.read.registry.CompositeReaderRegistryBuilder; +import io.fd.honeycomb.translate.read.ReaderFactory; import io.fd.honeycomb.translate.read.registry.ReaderRegistry; -import io.fd.honeycomb.translate.read.registry.ReaderRegistryBuilder; +import java.util.HashSet; +import java.util.Set; public final class ReaderRegistryProvider extends ProviderTrait<ReaderRegistry> { - @Inject - private ModifiableReaderRegistryBuilder readerRegistryBuilder; + @Inject(optional = true) + private Set<ReaderFactory> readerFactories = new HashSet<>(); @Override protected ReaderRegistry create() { - return ((ReaderRegistryBuilder) readerRegistryBuilder).build(); + final CompositeReaderRegistryBuilder builder = new CompositeReaderRegistryBuilder(); + readerFactories.stream() + .forEach(it -> it.init(builder)); + return builder.build(); } } |