SpringBoot - Apache Camel Sample

README.md

@@ -160,7 +160,7 @@ More info on each sample:
 - [**Synchronous Update**](/springboot/src/main/java/io/temporal/samples/springboot/update): Learn how to use Synchronous Update feature with this purchase sample
 - [**Kafka Request / Reply**](/springboot/src/main/java/io/temporal/samples/springboot/kafka): Sample showing possible integration with event streaming platforms such as Kafka
 - [**Customize Options**](/springboot/src/main/java/io/temporal/samples/springboot/customize): Sample showing how to customize options such as WorkerOptions, WorkerFactoryOptions, etc (see options config [here](springboot/src/main/java/io/temporal/samples/springboot/customize/TemporalOptionsConfig.java))
-
+- [**Apache Camel Route**](/springboot/src/main/java/io/temporal/samples/springboot/camel): Sample showing how to start Workflow execution from a Camel Route
 
 #### Temporal Cloud
 To run any of the SpringBoot samples in your Temporal Cloud namespace:

build.gradle

@@ -29,6 +29,7 @@ subprojects {
         otelVersion = '1.30.1'
         otelVersionAlpha = "${otelVersion}-alpha"
         javaSDKVersion = '1.22.3'
+        camelVersion = '3.22.1'
         jarVersion = '1.0.0'
     }
 

springboot/build.gradle

@@ -9,6 +9,8 @@ dependencies {
     // we set this as impl depends to use embedded kafka in samples not just tests
     implementation "org.springframework.kafka:spring-kafka-test"
     implementation "io.temporal:temporal-spring-boot-starter-alpha:$javaSDKVersion"
+    implementation "org.apache.camel.springboot:camel-spring-boot-starter:$camelVersion"
+    implementation "org.apache.camel.springboot:camel-servlet-starter:$camelVersion"
     runtimeOnly "io.micrometer:micrometer-registry-prometheus"
     runtimeOnly "com.h2database:h2"
     testImplementation "org.springframework.boot:spring-boot-starter-test"

springboot/src/main/java/io/temporal/samples/springboot/SamplesController.java

@@ -127,7 +127,7 @@ ResponseEntity purchase(@RequestBody Purchase purchase) {
   }
 
   @GetMapping("/kafka")
-  public String afka(Model model) {
+  public String kafka(Model model) {
     model.addAttribute("sample", "Kafka Request / Reply");
     return "kafka";
   }
@@ -176,4 +176,10 @@ ResponseEntity customizeSample() {
     // bypass thymeleaf, don't return template name just result
     return new ResponseEntity<>("\"" + workflow.execute() + "\"", HttpStatus.OK);
   }
+
+  @GetMapping("/camel")
+  public String camel(Model model) {
+    model.addAttribute("sample", "Camel Route");
+    return "camel";
+  }
 }

springboot/src/main/java/io/temporal/samples/springboot/camel/CamelConfig.java

@@ -0,0 +1,55 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.ConsumerTemplate;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.component.servlet.CamelHttpTransportServlet;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.web.servlet.ServletRegistrationBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+@Configuration()
+@Profile("!test")
+public class CamelConfig {
+  @Autowired private CamelContext camelContext;
+
+  @Bean
+  ServletRegistrationBean servletRegistrationBean() {
+    String contextPath = "/temporalapp";
+    ServletRegistrationBean servlet =
+        new ServletRegistrationBean(new CamelHttpTransportServlet(), contextPath + "/*");
+    servlet.setName("CamelServlet");
+    return servlet;
+  }
+
+  @Bean
+  ProducerTemplate producerTemplate() {
+    return camelContext.createProducerTemplate();
+  }
+
+  @Bean
+  ConsumerTemplate consumerTemplate() {
+    return camelContext.createConsumerTemplate();
+  }
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/CamelResource.java

@@ -0,0 +1,41 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import java.util.List;
+import org.apache.camel.ProducerTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class CamelResource {
+  @Autowired private ProducerTemplate producerTemplate;
+
+  @GetMapping("/orders")
+  @ResponseBody
+  public List<OfficeOrder> getProductsByCategory() {
+    producerTemplate.start();
+    List<OfficeOrder> orders = producerTemplate.requestBody("direct:getOrders", null, List.class);
+    producerTemplate.stop();
+    return orders;
+  }
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/CamelRoutes.java

@@ -0,0 +1,51 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import io.temporal.client.WorkflowClient;
+import io.temporal.client.WorkflowOptions;
+import org.apache.camel.builder.RouteBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class CamelRoutes extends RouteBuilder {
+
+  @Autowired private WorkflowClient workflowClient;
+
+  @Override
+  public void configure() {
+    from("direct:getOrders")
+        .routeId("direct-getOrders")
+        .tracing()
+        .process(
+            exchange -> {
+              OrderWorkflow workflow =
+                  workflowClient.newWorkflowStub(
+                      OrderWorkflow.class,
+                      WorkflowOptions.newBuilder()
+                          .setWorkflowId("CamelSampleWorkflow")
+                          .setTaskQueue("CamelSampleTaskQueue")
+                          .build());
+              exchange.getIn().setBody(workflow.start());
+            })
+        .end();
+  }
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/OfficeOrder.java

@@ -0,0 +1,92 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import javax.persistence.*;
+
+@Entity
+@Table(name = "officeorder")
+public class OfficeOrder {
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Integer id;
+
+  @Column(nullable = false)
+  private String number;
+
+  @Column(nullable = false)
+  private String desc;
+
+  @Column(nullable = false)
+  private String date;
+
+  @Column(nullable = false)
+  private double price;
+
+  public OfficeOrder() {}
+
+  public OfficeOrder(Integer id, String number, String desc, String date, double price) {
+    this.id = id;
+    this.number = number;
+    this.desc = desc;
+    this.date = date;
+    this.price = price;
+  }
+
+  public String getDesc() {
+    return desc;
+  }
+
+  public void setDesc(String desc) {
+    this.desc = desc;
+  }
+
+  public String getNumber() {
+    return number;
+  }
+
+  public Integer getId() {
+    return id;
+  }
+
+  public void setId(Integer id) {
+    this.id = id;
+  }
+
+  public void setNumber(String number) {
+    this.number = number;
+  }
+
+  public String getDate() {
+    return date;
+  }
+
+  public void setDate(String date) {
+    this.date = date;
+  }
+
+  public double getPrice() {
+    return price;
+  }
+
+  public void setPrice(double price) {
+    this.price = price;
+  }
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/OrderActivity.java

@@ -0,0 +1,28 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import io.temporal.activity.ActivityInterface;
+import java.util.List;
+
+@ActivityInterface
+public interface OrderActivity {
+  List<OfficeOrder> getOrders();
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/OrderActivityImpl.java

@@ -0,0 +1,37 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import io.temporal.spring.boot.ActivityImpl;
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+@ActivityImpl(taskQueues = "CamelSampleTaskQueue")
+public class OrderActivityImpl implements OrderActivity {
+
+  @Autowired OrderRepository repository;
+
+  @Override
+  public List<OfficeOrder> getOrders() {
+    return repository.findAll();
+  }
+}

springboot/src/main/java/io/temporal/samples/springboot/camel/OrderRepository.java

@@ -0,0 +1,26 @@
+/*
+ *  Copyright (c) 2020 Temporal Technologies, Inc. All Rights Reserved
+ *
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package io.temporal.samples.springboot.camel;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface OrderRepository extends JpaRepository<OfficeOrder, Integer> {}