org.robokind.demo.robot.replication.lifecycle
Class CollectorLifecycleUtils

java.lang.Object
  org.robokind.demo.robot.replication.lifecycle.CollectorLifecycleUtils

public class CollectorLifecycleUtils
extends Object

Author:

Matthew Stevenson

Constructor Summary

CollectorLifecycleUtils()

Method Summary

static org.jflux.api.core.config.Configuration<String>	buildBufferTrackerLifecycleConfig(org.osgi.framework.BundleContext context, String collectorIdKey, String collectorId, String trackerIdKey, String trackerId, String bufferFilterString)
static org.jflux.api.core.config.Configuration<String>	buildCollectionTriggerLinkLifecycleConfig(String linkId, String producerNodeIdKey, String producerNodeId, String collectorIdKey, String collectorId)
static org.jflux.api.core.config.Configuration<String>	buildEventCollectorLifecycleConfig(String collectorIdKey, String collectorId, Properties props)
static org.jflux.api.core.config.Configuration<String>	buildIntervalTimerLifecycleConfig(String timerIdKey, String timerId, long initialDelay, long period, Properties props)
static org.jflux.api.core.config.Configuration<String>	buildIntervalTimerLifecycleConfig(String timerIdKey, String timerId, long initialDelay, long period, org.jflux.api.core.Source messageSource, Properties props)
static org.jflux.api.core.config.Configuration<String>	buildSenderLinkLifecycleConfig(String linkId, String collectorIdKey, String collectorId, String senderNodeIdKey, String senderNodeId)
static List<org.jflux.api.core.config.Configuration<String>>	buildTimedCollector(org.osgi.framework.BundleContext context, String collectorIdKey, String collectorId, Properties collectorProps, String trackerIdKey, String trackerId, String bufferFilterString, String senderLinkId, String senderNodeIdKey, String senderNodeId, String timerlinkId, String timerNodeIdKey, String timerNodeId, long initialDelay, long period, Properties timerProps)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectorLifecycleUtils

public CollectorLifecycleUtils()

Method Detail

buildTimedCollector

public static List<org.jflux.api.core.config.Configuration<String>> buildTimedCollector(org.osgi.framework.BundleContext context,
                                                                                        String collectorIdKey,
                                                                                        String collectorId,
                                                                                        Properties collectorProps,
                                                                                        String trackerIdKey,
                                                                                        String trackerId,
                                                                                        String bufferFilterString,
                                                                                        String senderLinkId,
                                                                                        String senderNodeIdKey,
                                                                                        String senderNodeId,
                                                                                        String timerlinkId,
                                                                                        String timerNodeIdKey,
                                                                                        String timerNodeId,
                                                                                        long initialDelay,
                                                                                        long period,
                                                                                        Properties timerProps)

buildEventCollectorLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildEventCollectorLifecycleConfig(String collectorIdKey,
                                                                                                 String collectorId,
                                                                                                 Properties props)

buildBufferTrackerLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildBufferTrackerLifecycleConfig(org.osgi.framework.BundleContext context,
                                                                                                String collectorIdKey,
                                                                                                String collectorId,
                                                                                                String trackerIdKey,
                                                                                                String trackerId,
                                                                                                String bufferFilterString)

buildSenderLinkLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildSenderLinkLifecycleConfig(String linkId,
                                                                                             String collectorIdKey,
                                                                                             String collectorId,
                                                                                             String senderNodeIdKey,
                                                                                             String senderNodeId)

buildCollectionTriggerLinkLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildCollectionTriggerLinkLifecycleConfig(String linkId,
                                                                                                        String producerNodeIdKey,
                                                                                                        String producerNodeId,
                                                                                                        String collectorIdKey,
                                                                                                        String collectorId)

buildIntervalTimerLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildIntervalTimerLifecycleConfig(String timerIdKey,
                                                                                                String timerId,
                                                                                                long initialDelay,
                                                                                                long period,
                                                                                                org.jflux.api.core.Source messageSource,
                                                                                                Properties props)

buildIntervalTimerLifecycleConfig

public static org.jflux.api.core.config.Configuration<String> buildIntervalTimerLifecycleConfig(String timerIdKey,
                                                                                                String timerId,
                                                                                                long initialDelay,
                                                                                                long period,
                                                                                                Properties props)