Class PollActivityTaskQueueResponse

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessageV3
io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse
All Implemented Interfaces:
com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, PollActivityTaskQueueResponseOrBuilder, Serializable

@Generated(value="protoc", comments="annotations:PollActivityTaskQueueResponse.java.pb.meta") public final class PollActivityTaskQueueResponse extends com.google.protobuf.GeneratedMessageV3 implements PollActivityTaskQueueResponseOrBuilder
Protobuf type temporal.api.workflowservice.v1.PollActivityTaskQueueResponse
See Also:
  • Field Details

    • TASK_TOKEN_FIELD_NUMBER

      public static final int TASK_TOKEN_FIELD_NUMBER
      See Also:
    • WORKFLOW_NAMESPACE_FIELD_NUMBER

      public static final int WORKFLOW_NAMESPACE_FIELD_NUMBER
      See Also:
    • WORKFLOW_TYPE_FIELD_NUMBER

      public static final int WORKFLOW_TYPE_FIELD_NUMBER
      See Also:
    • WORKFLOW_EXECUTION_FIELD_NUMBER

      public static final int WORKFLOW_EXECUTION_FIELD_NUMBER
      See Also:
    • ACTIVITY_TYPE_FIELD_NUMBER

      public static final int ACTIVITY_TYPE_FIELD_NUMBER
      See Also:
    • ACTIVITY_ID_FIELD_NUMBER

      public static final int ACTIVITY_ID_FIELD_NUMBER
      See Also:
    • HEADER_FIELD_NUMBER

      public static final int HEADER_FIELD_NUMBER
      See Also:
    • INPUT_FIELD_NUMBER

      public static final int INPUT_FIELD_NUMBER
      See Also:
    • HEARTBEAT_DETAILS_FIELD_NUMBER

      public static final int HEARTBEAT_DETAILS_FIELD_NUMBER
      See Also:
    • SCHEDULED_TIME_FIELD_NUMBER

      public static final int SCHEDULED_TIME_FIELD_NUMBER
      See Also:
    • CURRENT_ATTEMPT_SCHEDULED_TIME_FIELD_NUMBER

      public static final int CURRENT_ATTEMPT_SCHEDULED_TIME_FIELD_NUMBER
      See Also:
    • STARTED_TIME_FIELD_NUMBER

      public static final int STARTED_TIME_FIELD_NUMBER
      See Also:
    • ATTEMPT_FIELD_NUMBER

      public static final int ATTEMPT_FIELD_NUMBER
      See Also:
    • SCHEDULE_TO_CLOSE_TIMEOUT_FIELD_NUMBER

      public static final int SCHEDULE_TO_CLOSE_TIMEOUT_FIELD_NUMBER
      See Also:
    • START_TO_CLOSE_TIMEOUT_FIELD_NUMBER

      public static final int START_TO_CLOSE_TIMEOUT_FIELD_NUMBER
      See Also:
    • HEARTBEAT_TIMEOUT_FIELD_NUMBER

      public static final int HEARTBEAT_TIMEOUT_FIELD_NUMBER
      See Also:
    • RETRY_POLICY_FIELD_NUMBER

      public static final int RETRY_POLICY_FIELD_NUMBER
      See Also:
    • POLLER_SCALING_DECISION_FIELD_NUMBER

      public static final int POLLER_SCALING_DECISION_FIELD_NUMBER
      See Also:
    • PRIORITY_FIELD_NUMBER

      public static final int PRIORITY_FIELD_NUMBER
      See Also:
    • ACTIVITY_RUN_ID_FIELD_NUMBER

      public static final int ACTIVITY_RUN_ID_FIELD_NUMBER
      See Also:
    • POLLER_GROUP_INFOS_FIELD_NUMBER

      public static final int POLLER_GROUP_INFOS_FIELD_NUMBER
      See Also:
    • POLLER_GROUPS_INFO_FIELD_NUMBER

      public static final int POLLER_GROUPS_INFO_FIELD_NUMBER
      See Also:
  • Method Details

    • newInstance

      protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
      Overrides:
      newInstance in class com.google.protobuf.GeneratedMessageV3
    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3
    • getTaskToken

      public com.google.protobuf.ByteString getTaskToken()
       A unique identifier for this task
       
      bytes task_token = 1;
      Specified by:
      getTaskToken in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The taskToken.
    • getWorkflowNamespace

      public String getWorkflowNamespace()
       The namespace of the activity. If this is a workflow activity then this is the namespace of
       the workflow also. If this is a standalone activity then the name of this field is
       misleading, but retained for compatibility with workflow activities.
       
      string workflow_namespace = 2;
      Specified by:
      getWorkflowNamespace in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The workflowNamespace.
    • getWorkflowNamespaceBytes

      public com.google.protobuf.ByteString getWorkflowNamespaceBytes()
       The namespace of the activity. If this is a workflow activity then this is the namespace of
       the workflow also. If this is a standalone activity then the name of this field is
       misleading, but retained for compatibility with workflow activities.
       
      string workflow_namespace = 2;
      Specified by:
      getWorkflowNamespaceBytes in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The bytes for workflowNamespace.
    • hasWorkflowType

      public boolean hasWorkflowType()
       Type of the requesting workflow (if this is a workflow activity).
       
      .temporal.api.common.v1.WorkflowType workflow_type = 3;
      Specified by:
      hasWorkflowType in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the workflowType field is set.
    • getWorkflowType

      public WorkflowType getWorkflowType()
       Type of the requesting workflow (if this is a workflow activity).
       
      .temporal.api.common.v1.WorkflowType workflow_type = 3;
      Specified by:
      getWorkflowType in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The workflowType.
    • getWorkflowTypeOrBuilder

      public WorkflowTypeOrBuilder getWorkflowTypeOrBuilder()
       Type of the requesting workflow (if this is a workflow activity).
       
      .temporal.api.common.v1.WorkflowType workflow_type = 3;
      Specified by:
      getWorkflowTypeOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasWorkflowExecution

      public boolean hasWorkflowExecution()
       Execution info of the requesting workflow (if this is a workflow activity)
       
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;
      Specified by:
      hasWorkflowExecution in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the workflowExecution field is set.
    • getWorkflowExecution

      public WorkflowExecution getWorkflowExecution()
       Execution info of the requesting workflow (if this is a workflow activity)
       
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;
      Specified by:
      getWorkflowExecution in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The workflowExecution.
    • getWorkflowExecutionOrBuilder

      public WorkflowExecutionOrBuilder getWorkflowExecutionOrBuilder()
       Execution info of the requesting workflow (if this is a workflow activity)
       
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;
      Specified by:
      getWorkflowExecutionOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasActivityType

      public boolean hasActivityType()
      .temporal.api.common.v1.ActivityType activity_type = 5;
      Specified by:
      hasActivityType in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the activityType field is set.
    • getActivityType

      public ActivityType getActivityType()
      .temporal.api.common.v1.ActivityType activity_type = 5;
      Specified by:
      getActivityType in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The activityType.
    • getActivityTypeOrBuilder

      public ActivityTypeOrBuilder getActivityTypeOrBuilder()
      .temporal.api.common.v1.ActivityType activity_type = 5;
      Specified by:
      getActivityTypeOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • getActivityId

      public String getActivityId()
       The autogenerated or user specified identifier of this activity. Can be used to complete the
       activity via `RespondActivityTaskCompletedById`. May be re-used as long as the last usage
       has resolved, but unique IDs for every activity invocation is a good idea.
       Note that only a workflow activity ID may be autogenerated.
       
      string activity_id = 6;
      Specified by:
      getActivityId in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The activityId.
    • getActivityIdBytes

      public com.google.protobuf.ByteString getActivityIdBytes()
       The autogenerated or user specified identifier of this activity. Can be used to complete the
       activity via `RespondActivityTaskCompletedById`. May be re-used as long as the last usage
       has resolved, but unique IDs for every activity invocation is a good idea.
       Note that only a workflow activity ID may be autogenerated.
       
      string activity_id = 6;
      Specified by:
      getActivityIdBytes in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The bytes for activityId.
    • hasHeader

      public boolean hasHeader()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
       from the workflow to its activities. For example, tracing contexts.
       
      .temporal.api.common.v1.Header header = 7;
      Specified by:
      hasHeader in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the header field is set.
    • getHeader

      public Header getHeader()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
       from the workflow to its activities. For example, tracing contexts.
       
      .temporal.api.common.v1.Header header = 7;
      Specified by:
      getHeader in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The header.
    • getHeaderOrBuilder

      public HeaderOrBuilder getHeaderOrBuilder()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
       from the workflow to its activities. For example, tracing contexts.
       
      .temporal.api.common.v1.Header header = 7;
      Specified by:
      getHeaderOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasInput

      public boolean hasInput()
       Arguments to the activity invocation
       
      .temporal.api.common.v1.Payloads input = 8;
      Specified by:
      hasInput in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the input field is set.
    • getInput

      public Payloads getInput()
       Arguments to the activity invocation
       
      .temporal.api.common.v1.Payloads input = 8;
      Specified by:
      getInput in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The input.
    • getInputOrBuilder

      public PayloadsOrBuilder getInputOrBuilder()
       Arguments to the activity invocation
       
      .temporal.api.common.v1.Payloads input = 8;
      Specified by:
      getInputOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasHeartbeatDetails

      public boolean hasHeartbeatDetails()
       Details of the last heartbeat that was recorded for this activity as of the time this task
       was delivered.
       
      .temporal.api.common.v1.Payloads heartbeat_details = 9;
      Specified by:
      hasHeartbeatDetails in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the heartbeatDetails field is set.
    • getHeartbeatDetails

      public Payloads getHeartbeatDetails()
       Details of the last heartbeat that was recorded for this activity as of the time this task
       was delivered.
       
      .temporal.api.common.v1.Payloads heartbeat_details = 9;
      Specified by:
      getHeartbeatDetails in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The heartbeatDetails.
    • getHeartbeatDetailsOrBuilder

      public PayloadsOrBuilder getHeartbeatDetailsOrBuilder()
       Details of the last heartbeat that was recorded for this activity as of the time this task
       was delivered.
       
      .temporal.api.common.v1.Payloads heartbeat_details = 9;
      Specified by:
      getHeartbeatDetailsOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasScheduledTime

      public boolean hasScheduledTime()
       When was this task first scheduled
       
      .google.protobuf.Timestamp scheduled_time = 10;
      Specified by:
      hasScheduledTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the scheduledTime field is set.
    • getScheduledTime

      public com.google.protobuf.Timestamp getScheduledTime()
       When was this task first scheduled
       
      .google.protobuf.Timestamp scheduled_time = 10;
      Specified by:
      getScheduledTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The scheduledTime.
    • getScheduledTimeOrBuilder

      public com.google.protobuf.TimestampOrBuilder getScheduledTimeOrBuilder()
       When was this task first scheduled
       
      .google.protobuf.Timestamp scheduled_time = 10;
      Specified by:
      getScheduledTimeOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasCurrentAttemptScheduledTime

      public boolean hasCurrentAttemptScheduledTime()
       When was this task attempt scheduled
       
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;
      Specified by:
      hasCurrentAttemptScheduledTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the currentAttemptScheduledTime field is set.
    • getCurrentAttemptScheduledTime

      public com.google.protobuf.Timestamp getCurrentAttemptScheduledTime()
       When was this task attempt scheduled
       
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;
      Specified by:
      getCurrentAttemptScheduledTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The currentAttemptScheduledTime.
    • getCurrentAttemptScheduledTimeOrBuilder

      public com.google.protobuf.TimestampOrBuilder getCurrentAttemptScheduledTimeOrBuilder()
       When was this task attempt scheduled
       
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;
      Specified by:
      getCurrentAttemptScheduledTimeOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasStartedTime

      public boolean hasStartedTime()
       When was this task started (this attempt)
       
      .google.protobuf.Timestamp started_time = 12;
      Specified by:
      hasStartedTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the startedTime field is set.
    • getStartedTime

      public com.google.protobuf.Timestamp getStartedTime()
       When was this task started (this attempt)
       
      .google.protobuf.Timestamp started_time = 12;
      Specified by:
      getStartedTime in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The startedTime.
    • getStartedTimeOrBuilder

      public com.google.protobuf.TimestampOrBuilder getStartedTimeOrBuilder()
       When was this task started (this attempt)
       
      .google.protobuf.Timestamp started_time = 12;
      Specified by:
      getStartedTimeOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • getAttempt

      public int getAttempt()
       Starting at 1, the number of attempts to perform this activity
       
      int32 attempt = 13;
      Specified by:
      getAttempt in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The attempt.
    • hasScheduleToCloseTimeout

      public boolean hasScheduleToCloseTimeout()
       First scheduled -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration schedule_to_close_timeout = 14;
      Specified by:
      hasScheduleToCloseTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the scheduleToCloseTimeout field is set.
    • getScheduleToCloseTimeout

      public com.google.protobuf.Duration getScheduleToCloseTimeout()
       First scheduled -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration schedule_to_close_timeout = 14;
      Specified by:
      getScheduleToCloseTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The scheduleToCloseTimeout.
    • getScheduleToCloseTimeoutOrBuilder

      public com.google.protobuf.DurationOrBuilder getScheduleToCloseTimeoutOrBuilder()
       First scheduled -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration schedule_to_close_timeout = 14;
      Specified by:
      getScheduleToCloseTimeoutOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasStartToCloseTimeout

      public boolean hasStartToCloseTimeout()
       Current attempt start -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration start_to_close_timeout = 15;
      Specified by:
      hasStartToCloseTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the startToCloseTimeout field is set.
    • getStartToCloseTimeout

      public com.google.protobuf.Duration getStartToCloseTimeout()
       Current attempt start -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration start_to_close_timeout = 15;
      Specified by:
      getStartToCloseTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The startToCloseTimeout.
    • getStartToCloseTimeoutOrBuilder

      public com.google.protobuf.DurationOrBuilder getStartToCloseTimeoutOrBuilder()
       Current attempt start -> final result reported timeout
      
       (-- api-linter: core::0140::prepositions=disabled
           aip.dev/not-precedent: "to" is used to indicate interval. --)
       
      .google.protobuf.Duration start_to_close_timeout = 15;
      Specified by:
      getStartToCloseTimeoutOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasHeartbeatTimeout

      public boolean hasHeartbeatTimeout()
       Window within which the activity must report a heartbeat, or be timed out.
       
      .google.protobuf.Duration heartbeat_timeout = 16;
      Specified by:
      hasHeartbeatTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the heartbeatTimeout field is set.
    • getHeartbeatTimeout

      public com.google.protobuf.Duration getHeartbeatTimeout()
       Window within which the activity must report a heartbeat, or be timed out.
       
      .google.protobuf.Duration heartbeat_timeout = 16;
      Specified by:
      getHeartbeatTimeout in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The heartbeatTimeout.
    • getHeartbeatTimeoutOrBuilder

      public com.google.protobuf.DurationOrBuilder getHeartbeatTimeoutOrBuilder()
       Window within which the activity must report a heartbeat, or be timed out.
       
      .google.protobuf.Duration heartbeat_timeout = 16;
      Specified by:
      getHeartbeatTimeoutOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasRetryPolicy

      public boolean hasRetryPolicy()
       This is the retry policy the service uses which may be different from the one provided
       (or not) during activity scheduling. The service can override the provided one if some
       values are not specified or exceed configured system limits.
       
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;
      Specified by:
      hasRetryPolicy in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the retryPolicy field is set.
    • getRetryPolicy

      public RetryPolicy getRetryPolicy()
       This is the retry policy the service uses which may be different from the one provided
       (or not) during activity scheduling. The service can override the provided one if some
       values are not specified or exceed configured system limits.
       
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;
      Specified by:
      getRetryPolicy in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The retryPolicy.
    • getRetryPolicyOrBuilder

      public RetryPolicyOrBuilder getRetryPolicyOrBuilder()
       This is the retry policy the service uses which may be different from the one provided
       (or not) during activity scheduling. The service can override the provided one if some
       values are not specified or exceed configured system limits.
       
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;
      Specified by:
      getRetryPolicyOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasPollerScalingDecision

      public boolean hasPollerScalingDecision()
       Server-advised information the SDK may use to adjust its poller count.
       
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;
      Specified by:
      hasPollerScalingDecision in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the pollerScalingDecision field is set.
    • getPollerScalingDecision

      public PollerScalingDecision getPollerScalingDecision()
       Server-advised information the SDK may use to adjust its poller count.
       
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;
      Specified by:
      getPollerScalingDecision in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The pollerScalingDecision.
    • getPollerScalingDecisionOrBuilder

      public PollerScalingDecisionOrBuilder getPollerScalingDecisionOrBuilder()
       Server-advised information the SDK may use to adjust its poller count.
       
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;
      Specified by:
      getPollerScalingDecisionOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasPriority

      public boolean hasPriority()
       Priority metadata
       
      .temporal.api.common.v1.Priority priority = 19;
      Specified by:
      hasPriority in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the priority field is set.
    • getPriority

      public Priority getPriority()
       Priority metadata
       
      .temporal.api.common.v1.Priority priority = 19;
      Specified by:
      getPriority in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The priority.
    • getPriorityOrBuilder

      public PriorityOrBuilder getPriorityOrBuilder()
       Priority metadata
       
      .temporal.api.common.v1.Priority priority = 19;
      Specified by:
      getPriorityOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • getActivityRunId

      public String getActivityRunId()
       The run ID of the activity execution, only set for standalone activities.
       
      string activity_run_id = 20;
      Specified by:
      getActivityRunId in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The activityRunId.
    • getActivityRunIdBytes

      public com.google.protobuf.ByteString getActivityRunIdBytes()
       The run ID of the activity execution, only set for standalone activities.
       
      string activity_run_id = 20;
      Specified by:
      getActivityRunIdBytes in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The bytes for activityRunId.
    • getPollerGroupInfosList

      @Deprecated public List<PollerGroupInfo> getPollerGroupInfosList()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
       queue. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];
      Specified by:
      getPollerGroupInfosList in interface PollActivityTaskQueueResponseOrBuilder
    • getPollerGroupInfosOrBuilderList

      @Deprecated public List<? extends PollerGroupInfoOrBuilder> getPollerGroupInfosOrBuilderList()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
       queue. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];
      Specified by:
      getPollerGroupInfosOrBuilderList in interface PollActivityTaskQueueResponseOrBuilder
    • getPollerGroupInfosCount

      @Deprecated public int getPollerGroupInfosCount()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
       queue. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];
      Specified by:
      getPollerGroupInfosCount in interface PollActivityTaskQueueResponseOrBuilder
    • getPollerGroupInfos

      @Deprecated public PollerGroupInfo getPollerGroupInfos(int index)
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
       queue. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];
      Specified by:
      getPollerGroupInfos in interface PollActivityTaskQueueResponseOrBuilder
    • getPollerGroupInfosOrBuilder

      @Deprecated public PollerGroupInfoOrBuilder getPollerGroupInfosOrBuilder(int index)
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
       queue. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];
      Specified by:
      getPollerGroupInfosOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • hasPollerGroupsInfo

      public boolean hasPollerGroupsInfo()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
       this task queue. Client should ignore this if it has already applied a snapshot with a
       version greater than or equal to `poller_groups_info.version`. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;
      Specified by:
      hasPollerGroupsInfo in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      Whether the pollerGroupsInfo field is set.
    • getPollerGroupsInfo

      public PollerGroupsInfo getPollerGroupsInfo()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
       this task queue. Client should ignore this if it has already applied a snapshot with a
       version greater than or equal to `poller_groups_info.version`. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;
      Specified by:
      getPollerGroupsInfo in interface PollActivityTaskQueueResponseOrBuilder
      Returns:
      The pollerGroupsInfo.
    • getPollerGroupsInfoOrBuilder

      public PollerGroupsInfoOrBuilder getPollerGroupsInfoOrBuilder()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
       this task queue. Client should ignore this if it has already applied a snapshot with a
       version greater than or equal to `poller_groups_info.version`. Client is expected to:
         1. Maintain minimum number of pollers no less than the number of groups.
         2. Try to assign the next poll to a group without any pending polls,
         3. If every group has some pending polls, assign the next poll to a group randomly
           according to the weights.
       
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;
      Specified by:
      getPollerGroupsInfoOrBuilder in interface PollActivityTaskQueueResponseOrBuilder
    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessageV3
    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessageV3
      Throws:
      IOException
    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessageV3
    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage
    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(InputStream input) throws IOException
      Throws:
      IOException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException
    • parseDelimitedFrom

      public static PollActivityTaskQueueResponse parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException
    • parseDelimitedFrom

      public static PollActivityTaskQueueResponse parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException
    • parseFrom

      public static PollActivityTaskQueueResponse parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException
    • newBuilderForType

      public PollActivityTaskQueueResponse.Builder newBuilderForType()
      Specified by:
      newBuilderForType in interface com.google.protobuf.Message
      Specified by:
      newBuilderForType in interface com.google.protobuf.MessageLite
    • newBuilder

      public static PollActivityTaskQueueResponse.Builder newBuilder()
    • newBuilder

    • toBuilder

      Specified by:
      toBuilder in interface com.google.protobuf.Message
      Specified by:
      toBuilder in interface com.google.protobuf.MessageLite
    • newBuilderForType

      protected PollActivityTaskQueueResponse.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
      Specified by:
      newBuilderForType in class com.google.protobuf.GeneratedMessageV3
    • getDefaultInstance

      public static PollActivityTaskQueueResponse getDefaultInstance()
    • parser

      public static com.google.protobuf.Parser<PollActivityTaskQueueResponse> parser()
    • getParserForType

      public com.google.protobuf.Parser<PollActivityTaskQueueResponse> getParserForType()
      Specified by:
      getParserForType in interface com.google.protobuf.Message
      Specified by:
      getParserForType in interface com.google.protobuf.MessageLite
      Overrides:
      getParserForType in class com.google.protobuf.GeneratedMessageV3
    • getDefaultInstanceForType

      public PollActivityTaskQueueResponse getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder