Package org.opennms.netmgt.flows.elastic
Class InitializingFlowRepository
- java.lang.Object
-
- org.opennms.netmgt.flows.elastic.InitializingFlowRepository
-
- All Implemented Interfaces:
FlowRepository
public class InitializingFlowRepository extends java.lang.Object implements FlowRepository
ThisFlowRepository
wrapper will ensure that the repository has been initialized before any *write* calls are made to the given delegate.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
InitializingFlowRepository(FlowRepository delegate, io.searchbox.client.JestClient client)
InitializingFlowRepository(org.osgi.framework.BundleContext bundleContext, FlowRepository delegate, io.searchbox.client.JestClient client, IndexSettings rawIndexSettings, IndexSettings aggIndexSettings)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
persist(java.util.Collection<Flow> flows, FlowSource source)
-
-
-
Constructor Detail
-
InitializingFlowRepository
public InitializingFlowRepository(org.osgi.framework.BundleContext bundleContext, FlowRepository delegate, io.searchbox.client.JestClient client, IndexSettings rawIndexSettings, IndexSettings aggIndexSettings)
-
InitializingFlowRepository
protected InitializingFlowRepository(FlowRepository delegate, io.searchbox.client.JestClient client)
-
-
Method Detail
-
persist
public void persist(java.util.Collection<Flow> flows, FlowSource source) throws FlowException
- Specified by:
persist
in interfaceFlowRepository
- Throws:
FlowException
-
-