Class AbstractCollectionAdapter

    • Field Detail

      • bundleContext

        protected org.osgi.framework.BundleContext bundleContext
    • Constructor Detail

      • AbstractCollectionAdapter

        public AbstractCollectionAdapter​(AdapterDefinition adapterConfig,
                                         com.codahale.metrics.MetricRegistry metricRegistry)
    • Method Detail

      • handleCollectionMessage

        public abstract java.util.stream.Stream<CollectionSetWithAgent> handleCollectionMessage​(TelemetryMessageLogEntry message,
                                                                                                TelemetryMessageLog messageLog)
        Build a collection set from the given message. The message log is also provided in case the log contains additional meta-data required. IMPORTANT: Implementations of this method must be thread-safe.
        Parameters:
        message - message to be converted into a collection set
        messageLog - message log to which the message belongs
        Returns:
        a CollectionSetWithAgent or an empty value if nothing should be persisted
        Throws:
        java.lang.Exception - if an error occured while generating the collection set
      • setFilterDao

        public void setFilterDao​(FilterDao filterDao)
      • setPersisterFactory

        public void setPersisterFactory​(PersisterFactory persisterFactory)
      • setThresholdingService

        public void setThresholdingService​(ThresholdingService thresholdingService)
      • setBundleContext

        public void setBundleContext​(org.osgi.framework.BundleContext bundleContext)