com.amazonaws.services.simpleworkflow.flow.worker

クラス GenericActivityWorker

java.lang.Object

com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker

com.amazonaws.services.simpleworkflow.flow.worker.GenericActivityWorker

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

Suspendable, SuspendableWorker, WorkerBase, WorkerLifecycle

public class GenericActivityWorker
extends GenericWorker

フィールドの概要

クラスから継承されたフィールド com.amazonaws.services.simpleworkflow.flow.worker.GenericWorker

domain, domainRetentionPeriodInDays, MAX_IDENTITY_LENGTH, registerDomain, service, suspendLatch, uncaughtExceptionHandler

コンストラクタの概要

コンストラクタ

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

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
protected void	checkRequredProperties()
protected TaskPoller	createPoller()
protected java.util.concurrent.Semaphore	createPollSemaphore()
ActivityImplementationFactory	getActivityImplementationFactory()
protected java.lang.String	getPollThreadNamePrefix()
int	getTaskExecutorThreadPoolSize()
static void	registerActivityType(AmazonSimpleWorkflow service, java.lang.String domain, ActivityType activityType, ActivityTypeRegistrationOptions registrationOptions, java.lang.String taskListToPoll)
static void	registerActivityTypes(AmazonSimpleWorkflow service, java.lang.String domain, java.lang.String defaultTaskList, ActivityImplementationFactory activityImplementationFactory)
void	registerTypesToPoll() Try to register every type (activity or workflow depending on worker) that are configured with the worker.
void	setActivityImplementationFactory(ActivityImplementationFactory activityImplementationFactory)
void	setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize)
java.lang.String	toString()

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

awaitTermination, checkRequiredProperty, checkStarted, getDomain, getDomainRetentionPeriodInDays, getIdentity, getMaximumPollRateIntervalMilliseconds, getMaximumPollRatePerSecond, getPollBackoffCoefficient, getPollBackoffInitialInterval, getPollBackoffMaximumInterval, getPollThreadCount, getService, getTaskListToPoll, getUncaughtExceptionHandler, isDisableServiceShutdownOnStop, isDisableTypeRegistrationOnStart, isRegisterDomain, isRunning, resumePolling, setDisableServiceShutdownOnStop, setDisableTypeRegistrationOnStart, setDomain, setDomainRetentionPeriodInDays, setIdentity, setMaximumPollRateIntervalMilliseconds, setMaximumPollRatePerSecond, setPollBackoffCoefficient, setPollBackoffInitialInterval, setPollBackoffMaximumInterval, setPollThreadCount, setRegisterDomain, setService, setTaskListToPoll, setUncaughtExceptionHandler, shutdown, shutdownAndAwaitTermination, shutdownNow, start, suspendPolling

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

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

コンストラクタの詳細

GenericActivityWorker

public GenericActivityWorker(AmazonSimpleWorkflow service,
                     java.lang.String domain,
                     java.lang.String taskListToPoll)

GenericActivityWorker

public GenericActivityWorker()

メソッドの詳細

getActivityImplementationFactory

public ActivityImplementationFactory getActivityImplementationFactory()

setActivityImplementationFactory

public void setActivityImplementationFactory(ActivityImplementationFactory activityImplementationFactory)

getTaskExecutorThreadPoolSize

public int getTaskExecutorThreadPoolSize()

setTaskExecutorThreadPoolSize

public void setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize)

createPollSemaphore

protected java.util.concurrent.Semaphore createPollSemaphore()

toString

public java.lang.String toString()

オーバーライド:

toString クラス内 GenericWorker

getPollThreadNamePrefix

protected java.lang.String getPollThreadNamePrefix()

定義:

getPollThreadNamePrefix クラス内 GenericWorker

createPoller

protected TaskPoller createPoller()

定義:

createPoller クラス内 GenericWorker

registerTypesToPoll

public void registerTypesToPoll()

インタフェースからコピーされた説明: WorkerBase

Try to register every type (activity or workflow depending on worker) that are configured with the worker.

関連項目:

WorkerBase.setDisableTypeRegistrationOnStart(boolean)

registerActivityTypes

public static void registerActivityTypes(AmazonSimpleWorkflow service,
                         java.lang.String domain,
                         java.lang.String defaultTaskList,
                         ActivityImplementationFactory activityImplementationFactory)

registerActivityType

public static void registerActivityType(AmazonSimpleWorkflow service,
                        java.lang.String domain,
                        ActivityType activityType,
                        ActivityTypeRegistrationOptions registrationOptions,
                        java.lang.String taskListToPoll)
                                 throws AmazonServiceException

例外:

AmazonServiceException

checkRequredProperties

protected void checkRequredProperties()

定義:

checkRequredProperties クラス内 GenericWorker