Class StreamDefinitionUtil

java.lang.Object
org.jboss.set.pull.processor.impl.evaluator.util.StreamDefinitionUtil

public class StreamDefinitionUtil extends Object
  • Constructor Details

    • StreamDefinitionUtil

      public StreamDefinitionUtil()
  • Method Details

    • matchStreams

      public static void matchStreams(org.jboss.set.aphrodite.Aphrodite aphrodite, List<StreamDefinition> defs) throws org.jboss.set.aphrodite.spi.NotFoundException
      Fetch stream/component definition from aphrodite if it match conf parameters(StreamDefinition and StreamComponentDefinition)
      Parameters:
      aphrodite -
      defs -
      Throws:
      org.jboss.set.aphrodite.spi.NotFoundException