Class InternalUtils

java.lang.Object
io.temporal.internal.common.InternalUtils
public final class InternalUtils extends Object
Utility functions shared by the implementation code.

  • Field Details

    • TEMPORAL_RESERVED_PREFIX

      public static String TEMPORAL_RESERVED_PREFIX

  • Method Details

    • createStickyTaskQueue

      public static io.temporal.api.taskqueue.v1.TaskQueue createStickyTaskQueue(String stickyTaskQueueName, String normalTaskQueueName)

    • createNormalTaskQueue

      public static io.temporal.api.taskqueue.v1.TaskQueue createNormalTaskQueue(String taskQueueName)

    • getValueOrDefault

      public static Object getValueOrDefault(Object value, Class<?> valueClass)

    • createNexusBoundStub

      public static NexusWorkflowStarter createNexusBoundStub(WorkflowStub stub, NexusStartWorkflowRequest request)
      Creates a new stub that is bound to the same workflow as the given stub, but with the Nexus callback URL and headers set.
      Parameters:
      stub - the stub to create a new stub from
      request - the request containing the Nexus callback URL and headers
      Returns:
      a new stub bound to the same workflow as the given stub, but with the Nexus callback URL and headers set

    • checkMethodName

      public static void checkMethodName(POJOWorkflowMethodMetadata methodMetadata)
      Check the method name for reserved prefixes or names.

    • checkMethodName

      public static void checkMethodName(POJOActivityMethodMetadata methodMetadata)

    • checkMethodName

      public static void checkMethodName(io.nexusrpc.handler.ServiceImplInstance instance)