use WorkerInterceptorBase

Author: stephanos

core/src/main/java/io/temporal/samples/countinterceptor/SimpleCountWorkerInterceptor.java

@@ -20,12 +20,10 @@
 package io.temporal.samples.countinterceptor;
 
 import io.nexusrpc.handler.OperationContext;
-import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
-import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
-import io.temporal.common.interceptors.WorkerInterceptor;
-import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
+import io.temporal.common.interceptors.*;
+import io.temporal.internal.sync.BaseRootWorkflowInboundCallsInterceptor;
 
-public class SimpleCountWorkerInterceptor implements WorkerInterceptor {
+public class SimpleCountWorkerInterceptor extends WorkerInterceptorBase {
 
   @Override
   public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInterceptor next) {
@@ -36,10 +34,4 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return new SimpleCountActivityInboundCallsInterceptor(next);
   }
-
-  @Override
-  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
-      OperationContext context, NexusOperationInboundCallsInterceptor next) {
-    return next;
-  }
 }

core/src/main/java/io/temporal/samples/excludefrominterceptor/interceptor/MyWorkerInterceptor.java

@@ -20,14 +20,12 @@
 package io.temporal.samples.excludefrominterceptor.interceptor;
 
 import io.nexusrpc.handler.OperationContext;
-import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
-import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
-import io.temporal.common.interceptors.WorkerInterceptor;
-import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
+import io.temporal.common.interceptors.*;
+
 import java.util.ArrayList;
 import java.util.List;
 
-public class MyWorkerInterceptor implements WorkerInterceptor {
+public class MyWorkerInterceptor extends WorkerInterceptorBase {
   private List<String> excludeWorkflowTypes = new ArrayList<>();
   private List<String> excludeActivityTypes = new ArrayList<>();
 
@@ -51,10 +49,4 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return new MyActivityInboundCallsInterceptor(excludeActivityTypes, next);
   }
-
-  @Override
-  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
-      OperationContext context, NexusOperationInboundCallsInterceptor next) {
-    return next;
-  }
 }

core/src/main/java/io/temporal/samples/retryonsignalinterceptor/RetryOnSignalWorkerInterceptor.java

@@ -20,13 +20,10 @@
 package io.temporal.samples.retryonsignalinterceptor;
 
 import io.nexusrpc.handler.OperationContext;
-import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
-import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
-import io.temporal.common.interceptors.WorkerInterceptor;
-import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
+import io.temporal.common.interceptors.*;
 
 /** Should be registered through WorkerFactoryOptions. */
-public class RetryOnSignalWorkerInterceptor implements WorkerInterceptor {
+public class RetryOnSignalWorkerInterceptor extends WorkerInterceptorBase {
   @Override
   public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInterceptor next) {
     return new RetryOnSignalWorkflowInboundCallsInterceptor(next);
@@ -36,10 +33,4 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return next;
   }
-
-  @Override
-  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
-      OperationContext context, NexusOperationInboundCallsInterceptor next) {
-    return next;
-  }
 }