You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pc...@apache.org on 2023/10/24 14:04:35 UTC
[camel-k] branch release-1.10.x updated: Remove route() from examples
This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch release-1.10.x
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/release-1.10.x by this push:
new a5157c8e8 Remove route() from examples
a5157c8e8 is described below
commit a5157c8e87637134a5350604889b32d9cdd5cba0
Author: Lucie Krejcirova <lf...@redhat.com>
AuthorDate: Tue Oct 24 14:58:12 2023 +0200
Remove route() from examples
---
examples/rest/routes-rest.js | 6 ++++--
examples/saga/Flight.java | 4 +++-
examples/saga/Payment.java | 4 +++-
examples/saga/Train.java | 4 +++-
examples/saga/lra-coordinator.yaml | 2 +-
5 files changed, 14 insertions(+), 6 deletions(-)
diff --git a/examples/rest/routes-rest.js b/examples/rest/routes-rest.js
index 264af31b6..3e39238ae 100644
--- a/examples/rest/routes-rest.js
+++ b/examples/rest/routes-rest.js
@@ -23,5 +23,7 @@
rest('/say/hello')
.produces("text/plain")
.get()
- .route()
- .transform().constant("Hello World");
+ .to('direct:sayHello')
+
+from('direct:sayHello')
+ .transform().constant("Hello World");
diff --git a/examples/saga/Flight.java b/examples/saga/Flight.java
index 5aacbd92d..51418301b 100644
--- a/examples/saga/Flight.java
+++ b/examples/saga/Flight.java
@@ -31,7 +31,9 @@ public class Flight extends RouteBuilder {
rest("/api").post("/flight/buy")
.param().type(RestParamType.header).name("id").required(true).endParam()
- .route()
+ .to("direct:buy");
+
+ from("direct:buy")
.saga()
.propagation(SagaPropagation.MANDATORY)
.option("id", header("id"))
diff --git a/examples/saga/Payment.java b/examples/saga/Payment.java
index 7eade73b0..0367d2dc7 100644
--- a/examples/saga/Payment.java
+++ b/examples/saga/Payment.java
@@ -31,7 +31,9 @@ public class Payment extends RouteBuilder {
rest("/api/").post("/pay")
.param().type(RestParamType.query).name("type").required(true).endParam()
.param().type(RestParamType.header).name("id").required(true).endParam()
- .route()
+ .to("direct:pay");
+
+ from("direct:pay")
.saga()
.propagation(SagaPropagation.MANDATORY)
.option("id", header("id"))
diff --git a/examples/saga/Train.java b/examples/saga/Train.java
index b46704d05..35aa5ec94 100644
--- a/examples/saga/Train.java
+++ b/examples/saga/Train.java
@@ -31,7 +31,9 @@ public class Train extends RouteBuilder {
rest("/api/").post("/train/buy/seat")
.param().type(RestParamType.header).name("id").required(true).endParam()
- .route()
+ .to("direct:buySeat");
+
+ from("direct:buySeat")
.saga()
.propagation(SagaPropagation.SUPPORTS)
.option("id", header("id"))
diff --git a/examples/saga/lra-coordinator.yaml b/examples/saga/lra-coordinator.yaml
index ef28c9fcb..68a31a299 100644
--- a/examples/saga/lra-coordinator.yaml
+++ b/examples/saga/lra-coordinator.yaml
@@ -79,7 +79,7 @@ spec:
scheme: HTTP
initialDelaySeconds: 180
name: lra-coordinator
- image: docker.io/jbosstm/lra-coordinator:5.9.8.Final
+ image: quay.io/jbosstm/lra-coordinator:latest
ports:
- containerPort: 8080
protocol: TCP