Skip to content

Commit aaa71d3

Browse files
author
Artur Ciocanu
committed
Adding logger to WorkflowActivityContext
1 parent bdb754b commit aaa71d3

File tree

3 files changed

+34
-0
lines changed

3 files changed

+34
-0
lines changed

sdk-workflows/src/main/java/io/dapr/workflows/WorkflowActivityContext.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,12 @@
1313

1414
package io.dapr.workflows;
1515

16+
import org.slf4j.Logger;
17+
1618
public interface WorkflowActivityContext {
1719

20+
Logger getLogger();
21+
1822
String getName();
1923

2024
String getTaskExecutionId();

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowActivityContext.java

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,15 @@
1515

1616
import io.dapr.durabletask.TaskActivityContext;
1717
import io.dapr.workflows.WorkflowActivityContext;
18+
import org.slf4j.Logger;
19+
import org.slf4j.LoggerFactory;
1820

1921
/**
2022
* Wrapper for Durable Task Framework {@link TaskActivityContext}.
2123
*/
2224
class DefaultWorkflowActivityContext implements WorkflowActivityContext {
2325
private final TaskActivityContext innerContext;
26+
private final Logger logger;
2427

2528
/**
2629
* Constructor for WorkflowActivityContext.
@@ -29,10 +32,36 @@ class DefaultWorkflowActivityContext implements WorkflowActivityContext {
2932
* @throws IllegalArgumentException if context is null
3033
*/
3134
public DefaultWorkflowActivityContext(TaskActivityContext context) throws IllegalArgumentException {
35+
this(context, LoggerFactory.getLogger(WorkflowActivityContext .class));
36+
}
37+
38+
/**
39+
* Constructor for WorkflowActivityContext.
40+
*
41+
* @param context TaskActivityContext
42+
* @throws IllegalArgumentException if context is null
43+
*/
44+
public DefaultWorkflowActivityContext(TaskActivityContext context, Logger logger) throws IllegalArgumentException {
3245
if (context == null) {
3346
throw new IllegalArgumentException("Context cannot be null");
3447
}
48+
49+
if (logger == null) {
50+
throw new IllegalArgumentException("Logger cannot be null");
51+
}
52+
3553
this.innerContext = context;
54+
this.logger = logger;
55+
}
56+
57+
/**
58+
* Gets the logger for the current activity.
59+
*
60+
* @return the logger for the current activity
61+
*/
62+
@Override
63+
public Logger getLogger() {
64+
return this.logger;
3665
}
3766

3867
/**

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowContext.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,7 @@ public DefaultWorkflowContext(TaskOrchestrationContext context, Logger logger)
6363
if (context == null) {
6464
throw new IllegalArgumentException("Context cannot be null");
6565
}
66+
6667
if (logger == null) {
6768
throw new IllegalArgumentException("Logger cannot be null");
6869
}

0 commit comments

Comments
 (0)