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 Object
implements FlowRepository

This FlowRepository 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

Modifier and Type	Method	Description
void	persist(Collection<Flow> flows, FlowSource source)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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(Collection<Flow> flows,
                    FlowSource source)
             throws FlowException

Specified by:

persist in interface FlowRepository

Throws:

FlowException