com.fluxtion.compiler.generation

Class EventProcessorFactory

java.lang.Object

com.fluxtion.compiler.generation.EventProcessorFactory

public class EventProcessorFactory
extends Object

Generates and compiles a SEP for use by a caller in the same process. The compilation is invoked programmatically removing the need to execute the Fluxtion event stream compiler as an external process.

To generate a SEP the caller invokes one of the static compileSep methods. An instance of EventProcessorConfig is passed to the consumer to control the graph construction, such as adding nodes and defining scopes or identifiers. Simple example adding a single node:

sepTestInstance((c) -> c.addNode(new MyHandler(), "handler"), "com.fluxtion.examples.inprocess", "GenNode_1");

Author:

V12 Technology Ltd.

Constructor Summary

Constructors

Constructor and Description
EventProcessorFactory()

Method Summary

Modifier and Type	Method and Description
static com.fluxtion.runtime.EventProcessor	compile(Consumer<EventProcessorConfig> cfgBuilder, String packageName, String className, String srcGenDir, String resGenDir, boolean initialise, boolean writeSourceFile, boolean generateMetaInformation) Compiles and instantiates a SEP described with the provided EventProcessorConfig, optionally initialising the SEP instance.
static com.fluxtion.runtime.EventProcessor	compile(EventProcessorConfig eventProcessorConfig, FluxtionCompilerConfig fluxtionCompilerConfig)
static com.fluxtion.runtime.EventProcessor	compile(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> builder)
static com.fluxtion.runtime.EventProcessor	compile(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> sepConfig, com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<FluxtionCompilerConfig> cfgBuilder)
static com.fluxtion.runtime.EventProcessor	compile(RootNodeConfig rootNode)
static com.fluxtion.runtime.EventProcessor	compile(RootNodeConfig rootNode, com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<FluxtionCompilerConfig> cfgBuilder)
static com.fluxtion.runtime.EventProcessor	compile(String name, String pkg, Consumer<EventProcessorConfig> builder) Build a static event processor using the supplied consumer to populate the SEPConfig.
static com.fluxtion.runtime.EventProcessor	compileTestInstance(Consumer<EventProcessorConfig> cfgBuilder, String pckg, String sepName, boolean writeSourceFile, boolean generateMetaInformation)
static InMemoryEventProcessor	interpreted(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> cfgBuilder)
static InMemoryEventProcessor	interpreted(RootNodeConfig rootNode)
static InMemoryEventProcessor	interpretedTest(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> cfgBuilder)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventProcessorFactory

public EventProcessorFactory()

Method Detail

interpreted

public static InMemoryEventProcessor interpreted(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> cfgBuilder)

interpreted

public static InMemoryEventProcessor interpreted(RootNodeConfig rootNode)

interpretedTest

public static InMemoryEventProcessor interpretedTest(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> cfgBuilder)

compile

public static com.fluxtion.runtime.EventProcessor compile(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> builder)
                                                   throws Exception

Throws:

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(RootNodeConfig rootNode)
                                                   throws Exception

Throws:

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(RootNodeConfig rootNode,
                                                          com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<FluxtionCompilerConfig> cfgBuilder)

compileTestInstance

public static com.fluxtion.runtime.EventProcessor compileTestInstance(Consumer<EventProcessorConfig> cfgBuilder,
                                                                      String pckg,
                                                                      String sepName,
                                                                      boolean writeSourceFile,
                                                                      boolean generateMetaInformation)
                                                               throws Exception

Throws:

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(String name,
                                                          String pkg,
                                                          Consumer<EventProcessorConfig> builder)
                                                   throws Exception

Build a static event processor using the supplied consumer to populate the SEPConfig. Will always build a new processor, supplying a newly created instance of the class to the caller.

Parameters:

name - The name of the generated static event processor

pkg - The package name of the generated static event processor

builder - The Consumer that populates the SEPConfig

Returns:

An instance of the newly generated static event processor

Throws:

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(Consumer<EventProcessorConfig> cfgBuilder,
                                                          String packageName,
                                                          String className,
                                                          String srcGenDir,
                                                          String resGenDir,
                                                          boolean initialise,
                                                          boolean writeSourceFile,
                                                          boolean generateMetaInformation)
                                                   throws InstantiationException,
                                                          IllegalAccessException,
                                                          Exception

Compiles and instantiates a SEP described with the provided EventProcessorConfig, optionally initialising the SEP instance.

Parameters:

cfgBuilder - - A client consumer to buld sep using the provided

packageName - - output package of the generated class

className - - output class name of the generated SEP

srcGenDir - - output directory for generated SEP source files

resGenDir - - output directory for generated resources

initialise - - if true call init method on SEP instance

Returns:

Throws:

InstantiationException

IllegalAccessException

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<EventProcessorConfig> sepConfig,
                                                          com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<FluxtionCompilerConfig> cfgBuilder)
                                                   throws Exception

Throws:

Exception

compile

public static com.fluxtion.runtime.EventProcessor compile(EventProcessorConfig eventProcessorConfig,
                                                          FluxtionCompilerConfig fluxtionCompilerConfig)
                                                   throws Exception

Throws:

Exception