Skip to content

Commit cd5b7c9

Browse files
committed
Merge remote-tracking branch 'core/main' into taskinteraction_
2 parents 0043cc8 + 323294a commit cd5b7c9

File tree

8 files changed

+29
-15
lines changed

8 files changed

+29
-15
lines changed

.github/workflows/gradle-wrapper-validation.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,4 @@ jobs:
77
runs-on: ubuntu-latest
88
steps:
99
- uses: actions/checkout@v4
10-
- uses: gradle/wrapper-validation-action@v2
10+
- uses: gradle/wrapper-validation-action@v3

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ subprojects {
2828
ext {
2929
otelVersion = '1.30.1'
3030
otelVersionAlpha = "${otelVersion}-alpha"
31-
javaSDKVersion = '1.23.1'
31+
javaSDKVersion = '1.23.2'
3232
camelVersion = '3.22.1'
3333
jarVersion = '1.0.0'
3434
}

core/build.gradle

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@ dependencies {
55
testImplementation("io.temporal:temporal-testing:$javaSDKVersion")
66

77
// Needed for SDK related functionality
8-
implementation(platform("com.fasterxml.jackson:jackson-bom:2.17.0"))
8+
implementation(platform("com.fasterxml.jackson:jackson-bom:2.17.1"))
99
implementation "com.fasterxml.jackson.core:jackson-databind"
1010
implementation "com.fasterxml.jackson.core:jackson-core"
1111

1212
implementation "io.micrometer:micrometer-registry-prometheus"
1313

14-
implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.5.3'
14+
implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.5.6'
1515
implementation group: 'com.jayway.jsonpath', name: 'json-path', version: '2.9.0'
1616

1717
implementation(platform("io.opentelemetry:opentelemetry-bom:$otelVersion"))
@@ -24,9 +24,9 @@ dependencies {
2424

2525
// Used in samples
2626
implementation group: 'commons-configuration', name: 'commons-configuration', version: '1.10'
27-
implementation group: 'io.cloudevents', name: 'cloudevents-core', version: '2.5.0'
28-
implementation group: 'io.cloudevents', name: 'cloudevents-api', version: '2.5.0'
29-
implementation group: 'io.cloudevents', name: 'cloudevents-json-jackson', version: '2.5.0'
27+
implementation group: 'io.cloudevents', name: 'cloudevents-core', version: '3.0.0'
28+
implementation group: 'io.cloudevents', name: 'cloudevents-api', version: '3.0.0'
29+
implementation group: 'io.cloudevents', name: 'cloudevents-json-jackson', version: '3.0.0'
3030
implementation group: 'io.serverlessworkflow', name: 'serverlessworkflow-api', version: '4.0.5.Final'
3131
implementation group: 'io.serverlessworkflow', name: 'serverlessworkflow-validation', version: '4.0.5.Final'
3232
implementation group: 'io.serverlessworkflow', name: 'serverlessworkflow-spi', version: '4.0.5.Final'
@@ -46,7 +46,7 @@ dependencies {
4646

4747
dependencies {
4848
errorproneJavac('com.google.errorprone:javac:9+181-r4173-1')
49-
errorprone('com.google.errorprone:error_prone_core:2.26.1')
49+
errorprone('com.google.errorprone:error_prone_core:2.27.1')
5050
}
5151
}
5252

springboot-basic/build.gradle

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,9 @@ dependencies {
1010
dependencies {
1111
errorproneJavac('com.google.errorprone:javac:9+181-r4173-1')
1212
if (JavaVersion.current().isJava11Compatible()) {
13-
errorprone('com.google.errorprone:error_prone_core:2.26.1')
13+
errorprone('com.google.errorprone:error_prone_core:2.27.1')
1414
} else {
15-
errorprone('com.google.errorprone:error_prone_core:2.26.1')
15+
errorprone('com.google.errorprone:error_prone_core:2.27.1')
1616
}
1717
}
1818
}

springboot/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ dependencies {
1616
testImplementation "org.springframework.boot:spring-boot-starter-test"
1717
dependencies {
1818
errorproneJavac('com.google.errorprone:javac:9+181-r4173-1')
19-
errorprone('com.google.errorprone:error_prone_core:2.26.1')
19+
errorprone('com.google.errorprone:error_prone_core:2.27.1')
2020
}
2121
}
2222

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
public class CamelRoutes extends RouteBuilder {
3030

3131
@Autowired private WorkflowClient workflowClient;
32+
@Autowired OrderRepository repository;
3233

3334
@Override
3435
public void configure() {
@@ -47,5 +48,13 @@ public void configure() {
4748
exchange.getIn().setBody(workflow.start());
4849
})
4950
.end();
51+
52+
from("direct:findAllOrders")
53+
.routeId("direct-findAllOrders")
54+
.process(
55+
exchange -> {
56+
exchange.getIn().setBody(repository.findAll());
57+
})
58+
.end();
5059
}
5160
}

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,17 +21,22 @@
2121

2222
import io.temporal.spring.boot.ActivityImpl;
2323
import java.util.List;
24+
import org.apache.camel.ProducerTemplate;
2425
import org.springframework.beans.factory.annotation.Autowired;
2526
import org.springframework.stereotype.Component;
2627

2728
@Component
2829
@ActivityImpl(taskQueues = "CamelSampleTaskQueue")
2930
public class OrderActivityImpl implements OrderActivity {
3031

31-
@Autowired OrderRepository repository;
32+
@Autowired private ProducerTemplate producerTemplate;
3233

3334
@Override
3435
public List<OfficeOrder> getOrders() {
35-
return repository.findAll();
36+
producerTemplate.start();
37+
List<OfficeOrder> orders =
38+
producerTemplate.requestBody("direct:findAllOrders", null, List.class);
39+
producerTemplate.stop();
40+
return orders;
3641
}
3742
}

springboot/src/main/java/io/temporal/samples/springboot/camel/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,5 +8,5 @@
88

99
http://localhost:3030/orders
1010

11-
This sample starts an Apache Camel route which runs our orders Workflow.
12-
Results of the workflow are returned by the Camel route
11+
This sample starts an Apache Camel route which starts our orders Workflow.
12+
The workflow starts an activity which starts Camel route to get all orders JPA.

0 commit comments

Comments
 (0)