Class NamespaceInjectWorkflowServiceStubs

java.lang.Object
io.temporal.internal.client.NamespaceInjectWorkflowServiceStubs
All Implemented Interfaces:
io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>, io.temporal.serviceclient.WorkflowServiceStubs
public class NamespaceInjectWorkflowServiceStubs extends Object implements io.temporal.serviceclient.WorkflowServiceStubs
Inject the namespace into the gRPC header, overriding the current namespace if already set.

  • Constructor Details

    • NamespaceInjectWorkflowServiceStubs

      public NamespaceInjectWorkflowServiceStubs(io.temporal.serviceclient.WorkflowServiceStubs next, String namespace)

  • Method Details

    • getOptions

      public io.temporal.serviceclient.WorkflowServiceStubsOptions getOptions()
      Specified by:
      getOptions in interface io.temporal.serviceclient.WorkflowServiceStubs

    • blockingStub

      public io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub blockingStub()
      Specified by:
      blockingStub in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • futureStub

      public io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub futureStub()
      Specified by:
      futureStub in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • getRawChannel

      public io.grpc.ManagedChannel getRawChannel()
      Specified by:
      getRawChannel in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • shutdown

      public void shutdown()
      Specified by:
      shutdown in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • shutdownNow

      public void shutdownNow()
      Specified by:
      shutdownNow in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • isShutdown

      public boolean isShutdown()
      Specified by:
      isShutdown in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • isTerminated

      public boolean isTerminated()
      Specified by:
      isTerminated in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • awaitTermination

      public boolean awaitTermination(long timeout, TimeUnit unit)
      Specified by:
      awaitTermination in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • connect

      public void connect(@Nullable Duration timeout)
      Specified by:
      connect in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • healthCheck

      public io.grpc.health.v1.HealthCheckResponse healthCheck()
      Specified by:
      healthCheck in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>

    • getServerCapabilities

      public Supplier<io.temporal.api.workflowservice.v1.GetSystemInfoResponse.Capabilities> getServerCapabilities()
      Specified by:
      getServerCapabilities in interface io.temporal.serviceclient.ServiceStubs<io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceBlockingStub,io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceFutureStub>