com.amazonaws.services.simpleworkflow.flow.worker

クラス SynchronousActivityTaskPoller

java.lang.Object

com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller

すべての実装されたインタフェース:

TaskPoller

直系の既知のサブクラス:

ActivityTaskPoller

public class SynchronousActivityTaskPoller
extends java.lang.Object
implements TaskPoller

コンストラクタの概要

コンストラクタ

コンストラクタと説明
SynchronousActivityTaskPoller()
SynchronousActivityTaskPoller(AmazonSimpleWorkflow service, java.lang.String domain, java.lang.String taskListToPoll, ActivityImplementationFactory activityImplementationFactory)

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
boolean	awaitTermination(long left, java.util.concurrent.TimeUnit milliseconds)
protected void	checkRequiredProperty(java.lang.Object value, java.lang.String name)
protected void	execute(ActivityTask task)
ActivityImplementationFactory	getActivityImplementationFactory()
java.lang.String	getDomain()
java.lang.String	getIdentity()
java.lang.String	getPollTaskList()
ExponentialRetryParameters	getReportCompletionRetryParameters()
ExponentialRetryParameters	getReportFailureRetryParameters()
AmazonSimpleWorkflow	getService()
java.lang.String	getTaskListToPoll()
ActivityTask	poll() Poll for a task using #getPollTimeoutInSeconds()
boolean	pollAndProcessSingleTask() Poll for a activity task and execute correspondent implementation.
protected void	respondActivityTaskCanceled(java.lang.String taskToken, java.lang.String details)
protected void	respondActivityTaskCanceledWithRetry(java.lang.String taskToken, java.lang.String details)
protected void	respondActivityTaskCompleted(java.lang.String taskToken, java.lang.String output)
protected void	respondActivityTaskCompletedWithRetry(java.lang.String taskToken, java.lang.String output)
protected void	respondActivityTaskFailed(java.lang.String taskToken, java.lang.String reason, java.lang.String details)
protected void	respondActivityTaskFailedWithRetry(java.lang.String taskToken, java.lang.String reason, java.lang.String details)
void	setActivityImplementationFactory(ActivityImplementationFactory activityImplementationFactory)
void	setDomain(java.lang.String domain)
void	setIdentity(java.lang.String identity)
void	setReportCompletionRetryParameters(ExponentialRetryParameters reportCompletionRetryParameters)
void	setReportFailureRetryParameters(ExponentialRetryParameters reportFailureRetryParameters)
void	setService(AmazonSimpleWorkflow service)
void	setTaskListToPoll(java.lang.String taskList)
void	shutdown()
void	shutdownNow()

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

コンストラクタの詳細

SynchronousActivityTaskPoller

public SynchronousActivityTaskPoller(AmazonSimpleWorkflow service,
                             java.lang.String domain,
                             java.lang.String taskListToPoll,
                             ActivityImplementationFactory activityImplementationFactory)

SynchronousActivityTaskPoller

public SynchronousActivityTaskPoller()

メソッドの詳細

getService

public AmazonSimpleWorkflow getService()

setService

public void setService(AmazonSimpleWorkflow service)

getDomain

public java.lang.String getDomain()

setDomain

public void setDomain(java.lang.String domain)

getPollTaskList

public java.lang.String getPollTaskList()

setTaskListToPoll

public void setTaskListToPoll(java.lang.String taskList)

getActivityImplementationFactory

public ActivityImplementationFactory getActivityImplementationFactory()

setActivityImplementationFactory

public void setActivityImplementationFactory(ActivityImplementationFactory activityImplementationFactory)

getIdentity

public java.lang.String getIdentity()

setIdentity

public void setIdentity(java.lang.String identity)

getReportCompletionRetryParameters

public ExponentialRetryParameters getReportCompletionRetryParameters()

setReportCompletionRetryParameters

public void setReportCompletionRetryParameters(ExponentialRetryParameters reportCompletionRetryParameters)

getReportFailureRetryParameters

public ExponentialRetryParameters getReportFailureRetryParameters()

setReportFailureRetryParameters

public void setReportFailureRetryParameters(ExponentialRetryParameters reportFailureRetryParameters)

getTaskListToPoll

public java.lang.String getTaskListToPoll()

poll

public ActivityTask poll()

Poll for a task using #getPollTimeoutInSeconds()

戻り値:

null if poll timed out

pollAndProcessSingleTask

public boolean pollAndProcessSingleTask()
                                 throws java.lang.Exception

Poll for a activity task and execute correspondent implementation.

定義:

pollAndProcessSingleTask インタフェース内 TaskPoller

戻り値:

true if task was polled and decided upon, false if poll timed out

例外:

java.lang.Exception

execute

protected void execute(ActivityTask task)
                throws java.lang.Exception

例外:

java.lang.Exception

respondActivityTaskFailedWithRetry

protected void respondActivityTaskFailedWithRetry(java.lang.String taskToken,
                                      java.lang.String reason,
                                      java.lang.String details)

respondActivityTaskFailed

protected void respondActivityTaskFailed(java.lang.String taskToken,
                             java.lang.String reason,
                             java.lang.String details)

respondActivityTaskCanceledWithRetry

protected void respondActivityTaskCanceledWithRetry(java.lang.String taskToken,
                                        java.lang.String details)

respondActivityTaskCanceled

protected void respondActivityTaskCanceled(java.lang.String taskToken,
                               java.lang.String details)

respondActivityTaskCompletedWithRetry

protected void respondActivityTaskCompletedWithRetry(java.lang.String taskToken,
                                         java.lang.String output)

respondActivityTaskCompleted

protected void respondActivityTaskCompleted(java.lang.String taskToken,
                                java.lang.String output)

checkRequiredProperty

protected void checkRequiredProperty(java.lang.Object value,
                         java.lang.String name)

shutdown

public void shutdown()

定義:

shutdown インタフェース内 TaskPoller

shutdownNow

public void shutdownNow()

定義:

shutdownNow インタフェース内 TaskPoller

awaitTermination

public boolean awaitTermination(long left,
                       java.util.concurrent.TimeUnit milliseconds)
                         throws java.lang.InterruptedException

定義:

awaitTermination インタフェース内 TaskPoller

例外:

java.lang.InterruptedException