upgrade Fluxtion to 9.347

v12technology · Nov 16, 2024 · b893caf · b893caf
1 parent db35370
commit b893caf
Show file tree

Hide file tree

Showing 15 changed files with 521 additions and 422 deletions.
diff --git a/...main/java/com/fluxtion/example/cookbook/dataingestion/pipeline/DataIngestionPipeline.java b/...main/java/com/fluxtion/example/cookbook/dataingestion/pipeline/DataIngestionPipeline.java
@@ -62,8 +62,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -489,6 +489,7 @@ public void registerService(com.fluxtion.runtime.service.Service<?> arg0) {
   }
   // EXPORTED SERVICE FUNCTIONS - END
 
+  // EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.runtime.time.ClockStrategy.ClockStrategyEvent) {
@@ -580,6 +581,7 @@ public void triggerCalculation() {
     }
     afterEvent();
   }
+  // EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/...a/com/fluxtion/example/cookbook/ml/linearregression/generated/OpportunityMlProcessor.java b/...a/com/fluxtion/example/cookbook/ml/linearregression/generated/OpportunityMlProcessor.java
@@ -64,8 +64,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -483,6 +483,7 @@ public void setProfitTrigger(double arg0) {
   }
   // EXPORTED SERVICE FUNCTIONS - END
 
+  // EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.example.cookbook.ml.linearregression.api.HouseSaleDetails) {
@@ -543,6 +544,7 @@ public void triggerCalculation() {
     }
     afterEvent();
   }
+  // EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/cookbook/src/main/java/com/fluxtion/example/cookbook/pnl/flatmapexample/PnlExampleMain.java b/cookbook/src/main/java/com/fluxtion/example/cookbook/pnl/flatmapexample/PnlExampleMain.java
@@ -12,6 +12,7 @@
 import com.fluxtion.example.cookbook.pnl.calculator.TradeLegToPositionAggregate;
 import com.fluxtion.example.cookbook.pnl.events.*;
 
+import com.fluxtion.example.cookbook.pnl.flatmapexample.generated.PnlFromFlatMapCalculator;
 import com.fluxtion.runtime.EventProcessor;
 
 import static com.fluxtion.example.cookbook.pnl.refdata.RefData.*;

diff --git a/.../com/fluxtion/example/cookbook/pnl/flatmapexample/generated/PnlFromFlatMapCalculator.java b/.../com/fluxtion/example/cookbook/pnl/flatmapexample/generated/PnlFromFlatMapCalculator.java
@@ -66,8 +66,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -402,25 +402,7 @@ public void handleEvent(Signal typedEvent) {
     switch (typedEvent.filterString()) {
         // Event Class:[com.fluxtion.runtime.event.Signal] filterString:[eob]
       case ("eob"):
-        isDirty_pnlSummaryCalc_3 = pnlSummaryCalc_3.eobTrigger(typedEvent);
-        if (isDirty_pnlSummaryCalc_3) {
-          mapRef2RefFlowFunction_2.publishTriggerOverrideNodeUpdated(pnlSummaryCalc_3);
-        }
-        if (guardCheck_mapRef2RefFlowFunction_2()) {
-          isDirty_mapRef2RefFlowFunction_2 = mapRef2RefFlowFunction_2.map();
-          if (isDirty_mapRef2RefFlowFunction_2) {
-            mapRef2RefFlowFunction_4.inputUpdated(mapRef2RefFlowFunction_2);
-          }
-        }
-        if (guardCheck_mapRef2RefFlowFunction_4()) {
-          isDirty_mapRef2RefFlowFunction_4 = mapRef2RefFlowFunction_4.map();
-          if (isDirty_mapRef2RefFlowFunction_4) {
-            peekFlowFunction_6.inputUpdated(mapRef2RefFlowFunction_4);
-          }
-        }
-        if (guardCheck_peekFlowFunction_6()) {
-          peekFlowFunction_6.peek();
-        }
+        handle_Signal_eob(typedEvent);
         afterEvent();
         return;
     }
@@ -436,6 +418,30 @@ public void handleEvent(ClockStrategyEvent typedEvent) {
   }
   // EVENT DISPATCH - END
 
+  // FILTERED DISPATCH - START
+  private void handle_Signal_eob(Signal typedEvent) {
+    isDirty_pnlSummaryCalc_3 = pnlSummaryCalc_3.eobTrigger(typedEvent);
+    if (isDirty_pnlSummaryCalc_3) {
+      mapRef2RefFlowFunction_2.publishTriggerOverrideNodeUpdated(pnlSummaryCalc_3);
+    }
+    if (guardCheck_mapRef2RefFlowFunction_2()) {
+      isDirty_mapRef2RefFlowFunction_2 = mapRef2RefFlowFunction_2.map();
+      if (isDirty_mapRef2RefFlowFunction_2) {
+        mapRef2RefFlowFunction_4.inputUpdated(mapRef2RefFlowFunction_2);
+      }
+    }
+    if (guardCheck_mapRef2RefFlowFunction_4()) {
+      isDirty_mapRef2RefFlowFunction_4 = mapRef2RefFlowFunction_4.map();
+      if (isDirty_mapRef2RefFlowFunction_4) {
+        peekFlowFunction_6.inputUpdated(mapRef2RefFlowFunction_4);
+      }
+    }
+    if (guardCheck_peekFlowFunction_6()) {
+      peekFlowFunction_6.peek();
+    }
+  }
+  // FILTERED DISPATCH - END
+
   // EXPORTED SERVICE FUNCTIONS - START
   @Override
   public void deRegisterService(com.fluxtion.runtime.service.Service<?> arg0) {
@@ -456,6 +462,7 @@ public void registerService(com.fluxtion.runtime.service.Service<?> arg0) {
   }
   // EXPORTED SERVICE FUNCTIONS - END
 
+  // EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     throw new UnsupportedOperationException("bufferEvent not supported");
   }

diff --git a/...n/java/com/fluxtion/example/cookbook/pnl/joinexample/generated/PnlFromJoinCalculator.java b/...n/java/com/fluxtion/example/cookbook/pnl/joinexample/generated/PnlFromJoinCalculator.java
@@ -67,8 +67,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -443,16 +443,7 @@ public void handleEvent(Signal typedEvent) {
     switch (typedEvent.filterString()) {
         // Event Class:[com.fluxtion.runtime.event.Signal] filterString:[eob]
       case ("eob"):
-        isDirty_pnlSummaryCalc_10 = pnlSummaryCalc_10.eobTrigger(typedEvent);
-        if (guardCheck_mapRef2RefFlowFunction_11()) {
-          isDirty_mapRef2RefFlowFunction_11 = mapRef2RefFlowFunction_11.map();
-          if (isDirty_mapRef2RefFlowFunction_11) {
-            peekFlowFunction_13.inputUpdated(mapRef2RefFlowFunction_11);
-          }
-        }
-        if (guardCheck_peekFlowFunction_13()) {
-          peekFlowFunction_13.peek();
-        }
+        handle_Signal_eob(typedEvent);
         afterEvent();
         return;
     }
@@ -468,6 +459,21 @@ public void handleEvent(ClockStrategyEvent typedEvent) {
   }
   // EVENT DISPATCH - END
 
+  // FILTERED DISPATCH - START
+  private void handle_Signal_eob(Signal typedEvent) {
+    isDirty_pnlSummaryCalc_10 = pnlSummaryCalc_10.eobTrigger(typedEvent);
+    if (guardCheck_mapRef2RefFlowFunction_11()) {
+      isDirty_mapRef2RefFlowFunction_11 = mapRef2RefFlowFunction_11.map();
+      if (isDirty_mapRef2RefFlowFunction_11) {
+        peekFlowFunction_13.inputUpdated(mapRef2RefFlowFunction_11);
+      }
+    }
+    if (guardCheck_peekFlowFunction_13()) {
+      peekFlowFunction_13.peek();
+    }
+  }
+  // FILTERED DISPATCH - END
+
   // EXPORTED SERVICE FUNCTIONS - START
   @Override
   public void deRegisterService(com.fluxtion.runtime.service.Service<?> arg0) {
@@ -488,6 +494,7 @@ public void registerService(com.fluxtion.runtime.service.Service<?> arg0) {
   }
   // EXPORTED SERVICE FUNCTIONS - END
 
+  // EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     throw new UnsupportedOperationException("bufferEvent not supported");
   }

diff --git a/...c/main/java/com/fluxtion/example/devworkflow/aot/generated/PermittedCommandProcessor.java b/...c/main/java/com/fluxtion/example/devworkflow/aot/generated/PermittedCommandProcessor.java
@@ -52,8 +52,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -284,6 +284,7 @@ public void registerService(com.fluxtion.runtime.service.Service<?> arg0) {
   }
   //EXPORTED SERVICE FUNCTIONS - END
 
+  //EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.example.devworkflow.integrating.AdminCommand) {
@@ -303,6 +304,7 @@ public void triggerCalculation() {
     String typedEvent = "No event information - buffered dispatch";
     afterEvent();
   }
+  //EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/...in/java/com/fluxtion/example/imperative/helloworld/generated/BreachNotifierProcessor.java b/...in/java/com/fluxtion/example/imperative/helloworld/generated/BreachNotifierProcessor.java
@@ -54,8 +54,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -295,6 +295,7 @@ public void registerService(com.fluxtion.runtime.service.Service<?> arg0) {
   }
   //EXPORTED SERVICE FUNCTIONS - END
 
+  //EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.example.imperative.helloworld.Event_A) {
@@ -324,6 +325,7 @@ public void triggerCalculation() {
     }
     afterEvent();
   }
+  //EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/jmh/src/main/java/com/fluxtion/example/jmh/pricer/generated/PriceLadderProcessor.java b/jmh/src/main/java/com/fluxtion/example/jmh/pricer/generated/PriceLadderProcessor.java
@@ -54,8 +54,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -321,6 +321,7 @@ public void setSkew(int arg0) {
   }
   //EXPORTED SERVICE FUNCTIONS - END
 
+  //EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.runtime.time.ClockStrategy.ClockStrategyEvent) {
@@ -347,6 +348,7 @@ public void triggerCalculation() {
     }
     afterEvent();
   }
+  //EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/.../main/java/com/fluxtion/example/jmh/pricer/generated/PriceLadderProcessorNoBranching.java b/.../main/java/com/fluxtion/example/jmh/pricer/generated/PriceLadderProcessorNoBranching.java
@@ -54,8 +54,8 @@
  *
  * <pre>
  * generation time                 : Not available
- * eventProcessorGenerator version : 9.3.46
- * api version                     : 9.3.46
+ * eventProcessorGenerator version : 9.3.47
+ * api version                     : 9.3.47
  * </pre>
  *
  * Event classes supported:
@@ -303,6 +303,7 @@ public void setSkew(int arg0) {
   }
   //EXPORTED SERVICE FUNCTIONS - END
 
+  //EVENT BUFFERING - START
   public void bufferEvent(Object event) {
     buffering = true;
     if (event instanceof com.fluxtion.runtime.time.ClockStrategy.ClockStrategyEvent) {
@@ -320,6 +321,7 @@ public void triggerCalculation() {
     priceLadderPublisher_0.publishPriceLadder();
     afterEvent();
   }
+  //EVENT BUFFERING - END
 
   private void auditEvent(Object typedEvent) {
     clock.eventReceived(typedEvent);

diff --git a/pom.xml b/pom.xml
@@ -47,7 +47,7 @@ along with this program.  If not, see
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <fluxtion.version>9.3.46</fluxtion.version>
+        <fluxtion.version>9.3.47</fluxtion.version>
         <fluxtion.mavenplugin.version>3.0.14</fluxtion.mavenplugin.version>
         <maven.compiler.source>21</maven.compiler.source>
         <maven.compiler.target>21</maven.compiler.target>