com.amazonaws.services.simpleworkflow.flow.worker

クラス ActivityTaskPoller

java.lang.Object

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

com.amazonaws.services.simpleworkflow.flow.worker.ActivityTaskPoller

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

TaskPoller

public class ActivityTaskPoller
extends SynchronousActivityTaskPoller

フィールドの概要

フィールド

修飾子とタイプ	フィールドと説明
protected java.util.concurrent.Semaphore	pollSemaphore

コンストラクタの概要

コンストラクタ

コンストラクタと説明
ActivityTaskPoller(AmazonSimpleWorkflow service, java.lang.String domain, java.lang.String pollTaskList, ActivityImplementationFactory activityImplementationFactory, java.util.concurrent.ThreadPoolExecutor taskExecutorService)

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
java.util.concurrent.ExecutorService	getTaskExecutorService()
boolean	pollAndProcessSingleTask() Poll for a activity task and execute correspondent implementation using provided executor service.
void	setTaskExecutorService(java.util.concurrent.ThreadPoolExecutor taskExecutorService)
void	shutdown()
void	shutdownNow()

クラスから継承されたメソッド com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller

checkRequiredProperty, execute, getActivityImplementationFactory, getDomain, getIdentity, getPollTaskList, getReportCompletionRetryParameters, getReportFailureRetryParameters, getService, getTaskListToPoll, poll, respondActivityTaskCanceled, respondActivityTaskCanceledWithRetry, respondActivityTaskCompleted, respondActivityTaskCompletedWithRetry, respondActivityTaskFailed, respondActivityTaskFailedWithRetry, setActivityImplementationFactory, setDomain, setIdentity, setReportCompletionRetryParameters, setReportFailureRetryParameters, setService, setTaskListToPoll

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

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

フィールドの詳細

pollSemaphore

protected java.util.concurrent.Semaphore pollSemaphore

コンストラクタの詳細

ActivityTaskPoller

public ActivityTaskPoller(AmazonSimpleWorkflow service,
                  java.lang.String domain,
                  java.lang.String pollTaskList,
                  ActivityImplementationFactory activityImplementationFactory,
                  java.util.concurrent.ThreadPoolExecutor taskExecutorService)

メソッドの詳細

getTaskExecutorService

public java.util.concurrent.ExecutorService getTaskExecutorService()

setTaskExecutorService

public void setTaskExecutorService(java.util.concurrent.ThreadPoolExecutor taskExecutorService)

pollAndProcessSingleTask

public boolean pollAndProcessSingleTask()
                                 throws java.lang.Exception

Poll for a activity task and execute correspondent implementation using provided executor service.

定義:

pollAndProcessSingleTask インタフェース内 TaskPoller

オーバーライド:

pollAndProcessSingleTask クラス内 SynchronousActivityTaskPoller

戻り値:

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

例外:

java.lang.Exception

shutdown

public void shutdown()

定義:

shutdown インタフェース内 TaskPoller

オーバーライド:

shutdown クラス内 SynchronousActivityTaskPoller

shutdownNow

public void shutdownNow()

定義:

shutdownNow インタフェース内 TaskPoller

オーバーライド:

shutdownNow クラス内 SynchronousActivityTaskPoller

awaitTermination

public boolean awaitTermination(long timeout,
                       java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

定義:

awaitTermination インタフェース内 TaskPoller

オーバーライド:

awaitTermination クラス内 SynchronousActivityTaskPoller

例外:

java.lang.InterruptedException