Package org.opennms.core.ipc.common.kafka

Class Utils

  • public class Utils
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor Description
      Utils()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.util.Properties getKafkaConfig​(Identity identity, org.osgi.service.cm.ConfigurationAdmin configAdmin, java.lang.String type)  
      static java.util.Set<java.lang.String> getTopics​(java.util.Properties kafkaConfig)  
      static <T> T runWithGivenClassLoader​(java.util.function.Supplier<T> supplier, java.lang.ClassLoader classLoader)  
      static <T> T runWithNullContextClassLoader​(java.util.function.Supplier<T> supplier)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Utils

        public Utils()

    • Method Detail

      • runWithNullContextClassLoader

        public static <T> T runWithNullContextClassLoader​(java.util.function.Supplier<T> supplier)

      • runWithGivenClassLoader

        public static <T> T runWithGivenClassLoader​(java.util.function.Supplier<T> supplier,
                                            java.lang.ClassLoader classLoader)

      • getTopics

        public static java.util.Set<java.lang.String> getTopics​(java.util.Properties kafkaConfig)
                                                 throws java.util.concurrent.ExecutionException,
                                                        java.lang.InterruptedException
        Throws:
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException

      • getKafkaConfig

        public static java.util.Properties getKafkaConfig​(Identity identity,
                                                  org.osgi.service.cm.ConfigurationAdmin configAdmin,
                                                  java.lang.String type)