class CadenceThrift::WorkflowService::Client

Public Instance Methods

CountWorkflowExecutions(countRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 625
def CountWorkflowExecutions(countRequest)
  send_CountWorkflowExecutions(countRequest)
  return recv_CountWorkflowExecutions()
end
DeprecateDomain(deprecateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 95
def DeprecateDomain(deprecateRequest)
  send_DeprecateDomain(deprecateRequest)
  recv_DeprecateDomain()
end
DescribeDomain(describeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 34
def DescribeDomain(describeRequest)
  send_DescribeDomain(describeRequest)
  return recv_DescribeDomain()
end
DescribeTaskList(request) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 749
def DescribeTaskList(request)
  send_DescribeTaskList(request)
  return recv_DescribeTaskList()
end
DescribeWorkflowExecution(describeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 728
def DescribeWorkflowExecution(describeRequest)
  send_DescribeWorkflowExecution(describeRequest)
  return recv_DescribeWorkflowExecution()
end
GetSearchAttributes() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 645
def GetSearchAttributes()
  send_GetSearchAttributes()
  return recv_GetSearchAttributes()
end
GetWorkflowExecutionHistory(getRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 138
def GetWorkflowExecutionHistory(getRequest)
  send_GetWorkflowExecutionHistory(getRequest)
  return recv_GetWorkflowExecutionHistory()
end
ListArchivedWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 585
def ListArchivedWorkflowExecutions(listRequest)
  send_ListArchivedWorkflowExecutions(listRequest)
  return recv_ListArchivedWorkflowExecutions()
end
ListClosedWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 545
def ListClosedWorkflowExecutions(listRequest)
  send_ListClosedWorkflowExecutions(listRequest)
  return recv_ListClosedWorkflowExecutions()
end
ListDomains(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 54
def ListDomains(listRequest)
  send_ListDomains(listRequest)
  return recv_ListDomains()
end
ListOpenWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 524
def ListOpenWorkflowExecutions(listRequest)
  send_ListOpenWorkflowExecutions(listRequest)
  return recv_ListOpenWorkflowExecutions()
end
ListWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 565
def ListWorkflowExecutions(listRequest)
  send_ListWorkflowExecutions(listRequest)
  return recv_ListWorkflowExecutions()
end
PollForActivityTask(pollRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 223
def PollForActivityTask(pollRequest)
  send_PollForActivityTask(pollRequest)
  return recv_PollForActivityTask()
end
PollForDecisionTask(pollRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 158
def PollForDecisionTask(pollRequest)
  send_PollForDecisionTask(pollRequest)
  return recv_PollForDecisionTask()
end
QueryWorkflow(queryRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 706
def QueryWorkflow(queryRequest)
  send_QueryWorkflow(queryRequest)
  return recv_QueryWorkflow()
end
RecordActivityTaskHeartbeat(heartbeatRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 245
def RecordActivityTaskHeartbeat(heartbeatRequest)
  send_RecordActivityTaskHeartbeat(heartbeatRequest)
  return recv_RecordActivityTaskHeartbeat()
end
RecordActivityTaskHeartbeatByID(heartbeatRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 267
def RecordActivityTaskHeartbeatByID(heartbeatRequest)
  send_RecordActivityTaskHeartbeatByID(heartbeatRequest)
  return recv_RecordActivityTaskHeartbeatByID()
end
RegisterDomain(registerRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 15
def RegisterDomain(registerRequest)
  send_RegisterDomain(registerRequest)
  recv_RegisterDomain()
end
RequestCancelWorkflowExecution(cancelRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 415
def RequestCancelWorkflowExecution(cancelRequest)
  send_RequestCancelWorkflowExecution(cancelRequest)
  recv_RequestCancelWorkflowExecution()
end
ResetStickyTaskList(resetRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 684
def ResetStickyTaskList(resetRequest)
  send_ResetStickyTaskList(resetRequest)
  return recv_ResetStickyTaskList()
end
ResetWorkflowExecution(resetRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 481
def ResetWorkflowExecution(resetRequest)
  send_ResetWorkflowExecution(resetRequest)
  return recv_ResetWorkflowExecution()
end
RespondActivityTaskCanceled(canceledRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 373
def RespondActivityTaskCanceled(canceledRequest)
  send_RespondActivityTaskCanceled(canceledRequest)
  recv_RespondActivityTaskCanceled()
end
RespondActivityTaskCanceledByID(canceledRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 394
def RespondActivityTaskCanceledByID(canceledRequest)
  send_RespondActivityTaskCanceledByID(canceledRequest)
  recv_RespondActivityTaskCanceledByID()
end
RespondActivityTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 289
def RespondActivityTaskCompleted(completeRequest)
  send_RespondActivityTaskCompleted(completeRequest)
  recv_RespondActivityTaskCompleted()
end
RespondActivityTaskCompletedByID(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 310
def RespondActivityTaskCompletedByID(completeRequest)
  send_RespondActivityTaskCompletedByID(completeRequest)
  recv_RespondActivityTaskCompletedByID()
end
RespondActivityTaskFailed(failRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 331
def RespondActivityTaskFailed(failRequest)
  send_RespondActivityTaskFailed(failRequest)
  recv_RespondActivityTaskFailed()
end
RespondActivityTaskFailedByID(failRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 352
def RespondActivityTaskFailedByID(failRequest)
  send_RespondActivityTaskFailedByID(failRequest)
  recv_RespondActivityTaskFailedByID()
end
RespondDecisionTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 180
def RespondDecisionTaskCompleted(completeRequest)
  send_RespondDecisionTaskCompleted(completeRequest)
  return recv_RespondDecisionTaskCompleted()
end
RespondDecisionTaskFailed(failedRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 202
def RespondDecisionTaskFailed(failedRequest)
  send_RespondDecisionTaskFailed(failedRequest)
  recv_RespondDecisionTaskFailed()
end
RespondQueryTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 663
def RespondQueryTaskCompleted(completeRequest)
  send_RespondQueryTaskCompleted(completeRequest)
  recv_RespondQueryTaskCompleted()
end
ScanWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 605
def ScanWorkflowExecutions(listRequest)
  send_ScanWorkflowExecutions(listRequest)
  return recv_ScanWorkflowExecutions()
end
SignalWithStartWorkflowExecution(signalWithStartRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 458
def SignalWithStartWorkflowExecution(signalWithStartRequest)
  send_SignalWithStartWorkflowExecution(signalWithStartRequest)
  return recv_SignalWithStartWorkflowExecution()
end
SignalWorkflowExecution(signalRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 437
def SignalWorkflowExecution(signalRequest)
  send_SignalWorkflowExecution(signalRequest)
  recv_SignalWorkflowExecution()
end
StartWorkflowExecution(startRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 115
def StartWorkflowExecution(startRequest)
  send_StartWorkflowExecution(startRequest)
  return recv_StartWorkflowExecution()
end
TerminateWorkflowExecution(terminateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 503
def TerminateWorkflowExecution(terminateRequest)
  send_TerminateWorkflowExecution(terminateRequest)
  recv_TerminateWorkflowExecution()
end
UpdateDomain(updateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 74
def UpdateDomain(updateRequest)
  send_UpdateDomain(updateRequest)
  return recv_UpdateDomain()
end
recv_CountWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 634
def recv_CountWorkflowExecutions()
  result = receive_message(CountWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CountWorkflowExecutions failed: unknown result')
end
recv_DeprecateDomain() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 104
def recv_DeprecateDomain()
  result = receive_message(DeprecateDomain_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_DescribeDomain() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 43
def recv_DescribeDomain()
  result = receive_message(DescribeDomain_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeDomain failed: unknown result')
end
recv_DescribeTaskList() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 758
def recv_DescribeTaskList()
  result = receive_message(DescribeTaskList_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeTaskList failed: unknown result')
end
recv_DescribeWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 737
def recv_DescribeWorkflowExecution()
  result = receive_message(DescribeWorkflowExecution_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeWorkflowExecution failed: unknown result')
end
recv_GetSearchAttributes() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 654
def recv_GetSearchAttributes()
  result = receive_message(GetSearchAttributes_result)
  return result.success unless result.success.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetSearchAttributes failed: unknown result')
end
recv_GetWorkflowExecutionHistory() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 147
def recv_GetWorkflowExecutionHistory()
  result = receive_message(GetWorkflowExecutionHistory_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetWorkflowExecutionHistory failed: unknown result')
end
recv_ListArchivedWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 594
def recv_ListArchivedWorkflowExecutions()
  result = receive_message(ListArchivedWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListArchivedWorkflowExecutions failed: unknown result')
end
recv_ListClosedWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 554
def recv_ListClosedWorkflowExecutions()
  result = receive_message(ListClosedWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListClosedWorkflowExecutions failed: unknown result')
end
recv_ListDomains() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 63
def recv_ListDomains()
  result = receive_message(ListDomains_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListDomains failed: unknown result')
end
recv_ListOpenWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 533
def recv_ListOpenWorkflowExecutions()
  result = receive_message(ListOpenWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListOpenWorkflowExecutions failed: unknown result')
end
recv_ListWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 574
def recv_ListWorkflowExecutions()
  result = receive_message(ListWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListWorkflowExecutions failed: unknown result')
end
recv_PollForActivityTask() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 232
def recv_PollForActivityTask()
  result = receive_message(PollForActivityTask_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'PollForActivityTask failed: unknown result')
end
recv_PollForDecisionTask() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 167
def recv_PollForDecisionTask()
  result = receive_message(PollForDecisionTask_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'PollForDecisionTask failed: unknown result')
end
recv_QueryWorkflow() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 715
def recv_QueryWorkflow()
  result = receive_message(QueryWorkflow_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.queryFailedError unless result.queryFailedError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'QueryWorkflow failed: unknown result')
end
recv_RecordActivityTaskHeartbeat() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 254
def recv_RecordActivityTaskHeartbeat()
  result = receive_message(RecordActivityTaskHeartbeat_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RecordActivityTaskHeartbeat failed: unknown result')
end
recv_RecordActivityTaskHeartbeatByID() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 276
def recv_RecordActivityTaskHeartbeatByID()
  result = receive_message(RecordActivityTaskHeartbeatByID_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RecordActivityTaskHeartbeatByID failed: unknown result')
end
recv_RegisterDomain() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 24
def recv_RegisterDomain()
  result = receive_message(RegisterDomain_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.domainExistsError unless result.domainExistsError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RequestCancelWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 424
def recv_RequestCancelWorkflowExecution()
  result = receive_message(RequestCancelWorkflowExecution_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.cancellationAlreadyRequestedError unless result.cancellationAlreadyRequestedError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_ResetStickyTaskList() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 693
def recv_ResetStickyTaskList()
  result = receive_message(ResetStickyTaskList_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetStickyTaskList failed: unknown result')
end
recv_ResetWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 490
def recv_ResetWorkflowExecution()
  result = receive_message(ResetWorkflowExecution_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetWorkflowExecution failed: unknown result')
end
recv_RespondActivityTaskCanceled() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 382
def recv_RespondActivityTaskCanceled()
  result = receive_message(RespondActivityTaskCanceled_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondActivityTaskCanceledByID() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 403
def recv_RespondActivityTaskCanceledByID()
  result = receive_message(RespondActivityTaskCanceledByID_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondActivityTaskCompleted() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 298
def recv_RespondActivityTaskCompleted()
  result = receive_message(RespondActivityTaskCompleted_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondActivityTaskCompletedByID() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 319
def recv_RespondActivityTaskCompletedByID()
  result = receive_message(RespondActivityTaskCompletedByID_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondActivityTaskFailed() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 340
def recv_RespondActivityTaskFailed()
  result = receive_message(RespondActivityTaskFailed_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondActivityTaskFailedByID() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 361
def recv_RespondActivityTaskFailedByID()
  result = receive_message(RespondActivityTaskFailedByID_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondDecisionTaskCompleted() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 189
def recv_RespondDecisionTaskCompleted()
  result = receive_message(RespondDecisionTaskCompleted_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RespondDecisionTaskCompleted failed: unknown result')
end
recv_RespondDecisionTaskFailed() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 211
def recv_RespondDecisionTaskFailed()
  result = receive_message(RespondDecisionTaskFailed_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_RespondQueryTaskCompleted() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 672
def recv_RespondQueryTaskCompleted()
  result = receive_message(RespondQueryTaskCompleted_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_ScanWorkflowExecutions() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 614
def recv_ScanWorkflowExecutions()
  result = receive_message(ScanWorkflowExecutions_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ScanWorkflowExecutions failed: unknown result')
end
recv_SignalWithStartWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 467
def recv_SignalWithStartWorkflowExecution()
  result = receive_message(SignalWithStartWorkflowExecution_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.workflowAlreadyStartedError unless result.workflowAlreadyStartedError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'SignalWithStartWorkflowExecution failed: unknown result')
end
recv_SignalWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 446
def recv_SignalWorkflowExecution()
  result = receive_message(SignalWorkflowExecution_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_StartWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 124
def recv_StartWorkflowExecution()
  result = receive_message(StartWorkflowExecution_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.sessionAlreadyExistError unless result.sessionAlreadyExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'StartWorkflowExecution failed: unknown result')
end
recv_TerminateWorkflowExecution() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 512
def recv_TerminateWorkflowExecution()
  result = receive_message(TerminateWorkflowExecution_result)
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.limitExceededError unless result.limitExceededError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  return
end
recv_UpdateDomain() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 83
def recv_UpdateDomain()
  result = receive_message(UpdateDomain_result)
  return result.success unless result.success.nil?
  raise result.badRequestError unless result.badRequestError.nil?
  raise result.internalServiceError unless result.internalServiceError.nil?
  raise result.entityNotExistError unless result.entityNotExistError.nil?
  raise result.serviceBusyError unless result.serviceBusyError.nil?
  raise result.domainNotActiveError unless result.domainNotActiveError.nil?
  raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'UpdateDomain failed: unknown result')
end
send_CountWorkflowExecutions(countRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 630
def send_CountWorkflowExecutions(countRequest)
  send_message('CountWorkflowExecutions', CountWorkflowExecutions_args, :countRequest => countRequest)
end
send_DeprecateDomain(deprecateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 100
def send_DeprecateDomain(deprecateRequest)
  send_message('DeprecateDomain', DeprecateDomain_args, :deprecateRequest => deprecateRequest)
end
send_DescribeDomain(describeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 39
def send_DescribeDomain(describeRequest)
  send_message('DescribeDomain', DescribeDomain_args, :describeRequest => describeRequest)
end
send_DescribeTaskList(request) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 754
def send_DescribeTaskList(request)
  send_message('DescribeTaskList', DescribeTaskList_args, :request => request)
end
send_DescribeWorkflowExecution(describeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 733
def send_DescribeWorkflowExecution(describeRequest)
  send_message('DescribeWorkflowExecution', DescribeWorkflowExecution_args, :describeRequest => describeRequest)
end
send_GetSearchAttributes() click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 650
def send_GetSearchAttributes()
  send_message('GetSearchAttributes', GetSearchAttributes_args)
end
send_GetWorkflowExecutionHistory(getRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 143
def send_GetWorkflowExecutionHistory(getRequest)
  send_message('GetWorkflowExecutionHistory', GetWorkflowExecutionHistory_args, :getRequest => getRequest)
end
send_ListArchivedWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 590
def send_ListArchivedWorkflowExecutions(listRequest)
  send_message('ListArchivedWorkflowExecutions', ListArchivedWorkflowExecutions_args, :listRequest => listRequest)
end
send_ListClosedWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 550
def send_ListClosedWorkflowExecutions(listRequest)
  send_message('ListClosedWorkflowExecutions', ListClosedWorkflowExecutions_args, :listRequest => listRequest)
end
send_ListDomains(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 59
def send_ListDomains(listRequest)
  send_message('ListDomains', ListDomains_args, :listRequest => listRequest)
end
send_ListOpenWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 529
def send_ListOpenWorkflowExecutions(listRequest)
  send_message('ListOpenWorkflowExecutions', ListOpenWorkflowExecutions_args, :listRequest => listRequest)
end
send_ListWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 570
def send_ListWorkflowExecutions(listRequest)
  send_message('ListWorkflowExecutions', ListWorkflowExecutions_args, :listRequest => listRequest)
end
send_PollForActivityTask(pollRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 228
def send_PollForActivityTask(pollRequest)
  send_message('PollForActivityTask', PollForActivityTask_args, :pollRequest => pollRequest)
end
send_PollForDecisionTask(pollRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 163
def send_PollForDecisionTask(pollRequest)
  send_message('PollForDecisionTask', PollForDecisionTask_args, :pollRequest => pollRequest)
end
send_QueryWorkflow(queryRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 711
def send_QueryWorkflow(queryRequest)
  send_message('QueryWorkflow', QueryWorkflow_args, :queryRequest => queryRequest)
end
send_RecordActivityTaskHeartbeat(heartbeatRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 250
def send_RecordActivityTaskHeartbeat(heartbeatRequest)
  send_message('RecordActivityTaskHeartbeat', RecordActivityTaskHeartbeat_args, :heartbeatRequest => heartbeatRequest)
end
send_RecordActivityTaskHeartbeatByID(heartbeatRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 272
def send_RecordActivityTaskHeartbeatByID(heartbeatRequest)
  send_message('RecordActivityTaskHeartbeatByID', RecordActivityTaskHeartbeatByID_args, :heartbeatRequest => heartbeatRequest)
end
send_RegisterDomain(registerRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 20
def send_RegisterDomain(registerRequest)
  send_message('RegisterDomain', RegisterDomain_args, :registerRequest => registerRequest)
end
send_RequestCancelWorkflowExecution(cancelRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 420
def send_RequestCancelWorkflowExecution(cancelRequest)
  send_message('RequestCancelWorkflowExecution', RequestCancelWorkflowExecution_args, :cancelRequest => cancelRequest)
end
send_ResetStickyTaskList(resetRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 689
def send_ResetStickyTaskList(resetRequest)
  send_message('ResetStickyTaskList', ResetStickyTaskList_args, :resetRequest => resetRequest)
end
send_ResetWorkflowExecution(resetRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 486
def send_ResetWorkflowExecution(resetRequest)
  send_message('ResetWorkflowExecution', ResetWorkflowExecution_args, :resetRequest => resetRequest)
end
send_RespondActivityTaskCanceled(canceledRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 378
def send_RespondActivityTaskCanceled(canceledRequest)
  send_message('RespondActivityTaskCanceled', RespondActivityTaskCanceled_args, :canceledRequest => canceledRequest)
end
send_RespondActivityTaskCanceledByID(canceledRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 399
def send_RespondActivityTaskCanceledByID(canceledRequest)
  send_message('RespondActivityTaskCanceledByID', RespondActivityTaskCanceledByID_args, :canceledRequest => canceledRequest)
end
send_RespondActivityTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 294
def send_RespondActivityTaskCompleted(completeRequest)
  send_message('RespondActivityTaskCompleted', RespondActivityTaskCompleted_args, :completeRequest => completeRequest)
end
send_RespondActivityTaskCompletedByID(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 315
def send_RespondActivityTaskCompletedByID(completeRequest)
  send_message('RespondActivityTaskCompletedByID', RespondActivityTaskCompletedByID_args, :completeRequest => completeRequest)
end
send_RespondActivityTaskFailed(failRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 336
def send_RespondActivityTaskFailed(failRequest)
  send_message('RespondActivityTaskFailed', RespondActivityTaskFailed_args, :failRequest => failRequest)
end
send_RespondActivityTaskFailedByID(failRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 357
def send_RespondActivityTaskFailedByID(failRequest)
  send_message('RespondActivityTaskFailedByID', RespondActivityTaskFailedByID_args, :failRequest => failRequest)
end
send_RespondDecisionTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 185
def send_RespondDecisionTaskCompleted(completeRequest)
  send_message('RespondDecisionTaskCompleted', RespondDecisionTaskCompleted_args, :completeRequest => completeRequest)
end
send_RespondDecisionTaskFailed(failedRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 207
def send_RespondDecisionTaskFailed(failedRequest)
  send_message('RespondDecisionTaskFailed', RespondDecisionTaskFailed_args, :failedRequest => failedRequest)
end
send_RespondQueryTaskCompleted(completeRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 668
def send_RespondQueryTaskCompleted(completeRequest)
  send_message('RespondQueryTaskCompleted', RespondQueryTaskCompleted_args, :completeRequest => completeRequest)
end
send_ScanWorkflowExecutions(listRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 610
def send_ScanWorkflowExecutions(listRequest)
  send_message('ScanWorkflowExecutions', ScanWorkflowExecutions_args, :listRequest => listRequest)
end
send_SignalWithStartWorkflowExecution(signalWithStartRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 463
def send_SignalWithStartWorkflowExecution(signalWithStartRequest)
  send_message('SignalWithStartWorkflowExecution', SignalWithStartWorkflowExecution_args, :signalWithStartRequest => signalWithStartRequest)
end
send_SignalWorkflowExecution(signalRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 442
def send_SignalWorkflowExecution(signalRequest)
  send_message('SignalWorkflowExecution', SignalWorkflowExecution_args, :signalRequest => signalRequest)
end
send_StartWorkflowExecution(startRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 120
def send_StartWorkflowExecution(startRequest)
  send_message('StartWorkflowExecution', StartWorkflowExecution_args, :startRequest => startRequest)
end
send_TerminateWorkflowExecution(terminateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 508
def send_TerminateWorkflowExecution(terminateRequest)
  send_message('TerminateWorkflowExecution', TerminateWorkflowExecution_args, :terminateRequest => terminateRequest)
end
send_UpdateDomain(updateRequest) click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 79
def send_UpdateDomain(updateRequest)
  send_message('UpdateDomain', UpdateDomain_args, :updateRequest => updateRequest)
end