File tree Expand file tree Collapse file tree 4 files changed +20
-4
lines changed
temporal-opentracing/src/test/java/io/temporal/opentracing Expand file tree Collapse file tree 4 files changed +20
-4
lines changed Original file line number Diff line number Diff line change 35
35
import io .temporal .common .RetryOptions ;
36
36
import io .temporal .failure .ApplicationFailure ;
37
37
import io .temporal .testing .TestWorkflowRule ;
38
+ import io .temporal .worker .WorkerFactoryOptions ;
38
39
import io .temporal .workflow .Workflow ;
39
40
import io .temporal .workflow .WorkflowInterface ;
40
41
import io .temporal .workflow .WorkflowMethod ;
@@ -58,7 +59,10 @@ public class OpenTracingActivityFailureTest {
58
59
WorkflowClientOptions .newBuilder ()
59
60
.setInterceptors (new OpenTracingClientInterceptor ())
60
61
.validateAndBuildWithDefaults ())
61
- .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
62
+ .setWorkerFactoryOptions (
63
+ WorkerFactoryOptions .newBuilder ()
64
+ .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
65
+ .validateAndBuildWithDefaults ())
62
66
.setWorkflowTypes (WorkflowImpl .class )
63
67
.setActivityImplementations (new FailingActivityImpl ())
64
68
.build ();
Original file line number Diff line number Diff line change 38
38
import io .temporal .client .WorkflowOptions ;
39
39
import io .temporal .failure .ApplicationFailure ;
40
40
import io .temporal .testing .TestWorkflowRule ;
41
+ import io .temporal .worker .WorkerFactoryOptions ;
41
42
import io .temporal .workflow .*;
42
43
import java .time .Duration ;
43
44
import org .junit .After ;
@@ -59,7 +60,10 @@ public class OpenTracingPropagationTrivialTest {
59
60
WorkflowClientOptions .newBuilder ()
60
61
.setInterceptors (new OpenTracingClientInterceptor ())
61
62
.validateAndBuildWithDefaults ())
62
- .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
63
+ .setWorkerFactoryOptions (
64
+ WorkerFactoryOptions .newBuilder ()
65
+ .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
66
+ .validateAndBuildWithDefaults ())
63
67
.setWorkflowTypes (WorkflowImpl .class )
64
68
.setActivityImplementations (new OpenTracingAwareActivityImpl ())
65
69
.build ();
Original file line number Diff line number Diff line change 34
34
import io .temporal .client .WorkflowOptions ;
35
35
import io .temporal .common .RetryOptions ;
36
36
import io .temporal .testing .TestWorkflowRule ;
37
+ import io .temporal .worker .WorkerFactoryOptions ;
37
38
import io .temporal .workflow .Workflow ;
38
39
import io .temporal .workflow .WorkflowInterface ;
39
40
import io .temporal .workflow .WorkflowMethod ;
@@ -57,7 +58,10 @@ public class OpenTracingWorkflowReplayTest {
57
58
WorkflowClientOptions .newBuilder ()
58
59
.setInterceptors (new OpenTracingClientInterceptor ())
59
60
.validateAndBuildWithDefaults ())
60
- .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
61
+ .setWorkerFactoryOptions (
62
+ WorkerFactoryOptions .newBuilder ()
63
+ .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
64
+ .validateAndBuildWithDefaults ())
61
65
.setWorkflowTypes (WorkflowImpl .class )
62
66
.setActivityImplementations (new ActivityImpl ())
63
67
.build ();
Original file line number Diff line number Diff line change 35
35
import io .temporal .common .RetryOptions ;
36
36
import io .temporal .failure .ApplicationFailure ;
37
37
import io .temporal .testing .TestWorkflowRule ;
38
+ import io .temporal .worker .WorkerFactoryOptions ;
38
39
import io .temporal .workflow .Workflow ;
39
40
import io .temporal .workflow .WorkflowInterface ;
40
41
import io .temporal .workflow .WorkflowMethod ;
@@ -58,7 +59,10 @@ public class OpenTracingWorkflowRetryTest {
58
59
WorkflowClientOptions .newBuilder ()
59
60
.setInterceptors (new OpenTracingClientInterceptor ())
60
61
.validateAndBuildWithDefaults ())
61
- .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
62
+ .setWorkerFactoryOptions (
63
+ WorkerFactoryOptions .newBuilder ()
64
+ .setWorkerInterceptors (new OpenTracingWorkerInterceptor ())
65
+ .validateAndBuildWithDefaults ())
62
66
.setWorkflowTypes (WorkflowImpl .class )
63
67
.setActivityImplementations (new ActivityImpl ())
64
68
.build ();
You can’t perform that action at this time.
0 commit comments