From a69b88bd5f67abb9eeecf4678510b5468676d83c Mon Sep 17 00:00:00 2001
From: YannC <ycoornaert@kestra.io>
Date: Mon, 5 Aug 2024 14:34:38 +0200
Subject: [PATCH] fix(Consume): reflect core changes

---
 build.gradle                                       | 2 +-
 src/main/java/io/kestra/plugin/solace/Consume.java | 2 +-
 src/main/java/io/kestra/plugin/solace/Trigger.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/build.gradle b/build.gradle
index b7be77f..6e0ea6c 100644
--- a/build.gradle
+++ b/build.gradle
@@ -91,7 +91,7 @@ dependencies {
     // test deps needed only for to have a runner
     testAnnotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
     testImplementation group: "io.kestra", name: "core", version: kestraVersion
-    testImplementation group: "io.kestra", name: "core", version: kestraVersion, classifier: "tests"
+    testImplementation group: "io.kestra", name: "tests", version: kestraVersion
     testImplementation group: "io.kestra", name: "repository-memory", version: kestraVersion
     testImplementation group: "io.kestra", name: "runner-memory", version: kestraVersion
     testImplementation group: "io.kestra", name: "storage-local", version: kestraVersion
diff --git a/src/main/java/io/kestra/plugin/solace/Consume.java b/src/main/java/io/kestra/plugin/solace/Consume.java
index 00ba834..ccdd2fc 100644
--- a/src/main/java/io/kestra/plugin/solace/Consume.java
+++ b/src/main/java/io/kestra/plugin/solace/Consume.java
@@ -96,7 +96,7 @@ public Output run(RunContext runContext) throws Exception {
 
     Output run(RunContext runContext, SolaceConsumeInterface task) throws Exception {
 
-        File tempFile = runContext.tempFile(".ion").toFile();
+        File tempFile = runContext.workingDir().createTempFile(".ion").toFile();
         try (
             BufferedOutputStream output = new BufferedOutputStream(new FileOutputStream(tempFile))
         ) {
diff --git a/src/main/java/io/kestra/plugin/solace/Trigger.java b/src/main/java/io/kestra/plugin/solace/Trigger.java
index c38057a..67eeb59 100644
--- a/src/main/java/io/kestra/plugin/solace/Trigger.java
+++ b/src/main/java/io/kestra/plugin/solace/Trigger.java
@@ -124,7 +124,7 @@ public Optional<Execution> evaluate(ConditionContext conditionContext,
             .id(runContext.getTriggerExecutionId())
             .namespace(context.getNamespace())
             .flowId(context.getFlowId())
-            .flowRevision(context.getFlowRevision())
+            .flowRevision(conditionContext.getFlow().getRevision())
             .state(new State())
             .trigger(executionTrigger)
             .build();