SpringActivityWorker

java.lang.Object
- com.amazonaws.services.simpleworkflow.flow.spring.SpringActivityWorker

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

Suspendable, SuspendableWorker, WorkerBase, WorkerLifecycle, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
```
public class SpringActivityWorker
extends java.lang.Object
implements WorkerBase, org.springframework.context.SmartLifecycle
```

コンストラクタの概要

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

メソッドの概要

メソッド
修飾子とタイプ	メソッドと説明
`java.util.List<ActivityType>`	`addActivitiesImplementation(java.lang.Object activitiesImplementation)`
`boolean`	`awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)`
`java.lang.Iterable<java.lang.Object>`	`getActivitiesImplementations()`
`DataConverter`	`getDataConverter()`
`java.lang.String`	`getDomain()`
`long`	`getDomainRetentionPeriodInDays()`
`java.lang.String`	`getIdentity()`
`int`	`getMaximumPollRateIntervalMilliseconds()`
`double`	`getMaximumPollRatePerSecond()`
`int`	`getPhase()`
`double`	`getPollBackoffCoefficient()`
`long`	`getPollBackoffInitialInterval()`
`long`	`getPollBackoffMaximumInterval()`
`int`	`getPollThreadCount()`
`AmazonSimpleWorkflow`	`getService()`
`int`	`getTaskExecutorThreadPoolSize()`
`java.lang.String`	`getTaskListToPoll()` Task list name that given worker polls for tasks.
`long`	`getTerminationTimeoutSeconds()`
`java.lang.Thread.UncaughtExceptionHandler`	`getUncaughtExceptionHandler()`
`boolean`	`isAutoStartup()`
`boolean`	`isDisableAutoStartup()`
`boolean`	`isDisableServiceShutdownOnStop()`
`boolean`	`isDisableTypeRegistrationOnStart()`
`boolean`	`isRegisterDomain()`
`boolean`	`isRunning()`
`void`	`registerTypesToPoll()` Try to register every type (activity or workflow depending on worker) that are configured with the worker.
`void`	`resumePolling()` Allow new poll requests.
`void`	`setActivitiesImplementations(java.lang.Iterable<java.lang.Object> activitiesImplementations)`
`void`	`setDataConverter(DataConverter dataConverter)`
`void`	`setDisableAutoStartup(boolean disableAutoStartup)`
`void`	`setDisableServiceShutdownOnStop(boolean disableServiceShutdownOnStop)` When set to false (which is default) at the beginning of the worker shutdown `AmazonSimpleWorkflow.shutdown()` is called.
`void`	`setDisableTypeRegistrationOnStart(boolean disableTypeRegistrationOnStart)` When set to true disables types registration on start even if `SkipTypeRegistration` is not specified.
`void`	`setDomain(java.lang.String domain)`
`void`	`setDomainRetentionPeriodInDays(long domainRetentionPeriodInDays)` Value of DomainRetentionPeriodInDays parameter passed to `AmazonSimpleWorkflow.registerDomain(com.amazonaws.services.simpleworkflow.model.RegisterDomainRequest)` call.
`void`	`setIdentity(java.lang.String identity)` Set the identity that worker specifies in the poll requests.
`void`	`setMaximumPollRateIntervalMilliseconds(int maximumPollRateIntervalMilliseconds)` The sliding window interval used to measure the poll rate.
`void`	`setMaximumPollRatePerSecond(double maximumPollRatePerSecond)` Maximum number of poll request to the task list per second allowed.
`void`	`setPhase(int startPhase)`
`void`	`setPollBackoffCoefficient(double backoffCoefficient)`
`void`	`setPollBackoffInitialInterval(long backoffInitialInterval)` Failed poll requests are retried after an interval defined by an exponential backoff algorithm.
`void`	`setPollBackoffMaximumInterval(long backoffMaximumInterval)`
`void`	`setPollThreadCount(int threadCount)` Defines how many concurrent threads are used by the given worker to poll the specified task list.
`void`	`setRegisterDomain(boolean registerDomain)` Should domain be registered on startup.
`void`	`setService(AmazonSimpleWorkflow service)`
`void`	`setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize)`
`void`	`setTaskListToPoll(java.lang.String taskListToPoll)`
`void`	`setTerminationTimeoutSeconds(long terminationTimeoutSeconds)`
`void`	`setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler uncaughtExceptionHandler)` Handler notified about poll request and other unexpected failures.
`void`	`shutdown()`
`boolean`	`shutdownAndAwaitTermination(long timeout, java.util.concurrent.TimeUnit unit)`
`void`	`shutdownNow()`
`void`	`start()`
`void`	`stop()`
`void`	`stop(java.lang.Runnable callback)`
`void`	`stopNow()`
`void`	`suspendPolling()` Do not make new poll requests.
`java.lang.String`	`toString()`

クラスから継承されたメソッド java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- コンストラクタの詳細
  - SpringActivityWorker
```
public SpringActivityWorker()
```
  - SpringActivityWorker
```
public SpringActivityWorker(AmazonSimpleWorkflow service,
                    java.lang.String domain,
                    java.lang.String taskListToPoll)
```
- メソッドの詳細
  - getService
```
public AmazonSimpleWorkflow getService()
```
    定義:
    
    getService インタフェース内 WorkerBase
  - setService
```
public void setService(AmazonSimpleWorkflow service)
```
  - getDomain
```
public java.lang.String getDomain()
```
    定義:
    
    getDomain インタフェース内 WorkerBase
  - setDomain
```
public void setDomain(java.lang.String domain)
```
  - isRegisterDomain
```
public boolean isRegisterDomain()
```
    定義:
    
    isRegisterDomain インタフェース内 WorkerBase
  - setRegisterDomain
```
public void setRegisterDomain(boolean registerDomain)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Should domain be registered on startup. Default is false. When enabled #setDomainRetentionPeriodInDays(Long) property is required.
    
    定義:
    
    setRegisterDomain インタフェース内 WorkerBase
  - getDomainRetentionPeriodInDays
```
public long getDomainRetentionPeriodInDays()
```
    定義:
    
    getDomainRetentionPeriodInDays インタフェース内 WorkerBase
  - setDomainRetentionPeriodInDays
```
public void setDomainRetentionPeriodInDays(long domainRetentionPeriodInDays)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Value of DomainRetentionPeriodInDays parameter passed to AmazonSimpleWorkflow.registerDomain(com.amazonaws.services.simpleworkflow.model.RegisterDomainRequest) call. Required when WorkerBase.isRegisterDomain() is true.
    
    定義:
    
    setDomainRetentionPeriodInDays インタフェース内 WorkerBase
  - getTaskListToPoll
```
public java.lang.String getTaskListToPoll()
```
    インタフェースからコピーされた説明: WorkerBase
    
    Task list name that given worker polls for tasks.
    
    定義:
    
    getTaskListToPoll インタフェース内 WorkerBase
  - setTaskListToPoll
```
public void setTaskListToPoll(java.lang.String taskListToPoll)
```
  - getDataConverter
```
public DataConverter getDataConverter()
```
  - setDataConverter
```
public void setDataConverter(DataConverter dataConverter)
```
  - getMaximumPollRatePerSecond
```
public double getMaximumPollRatePerSecond()
```
    定義:
    
    getMaximumPollRatePerSecond インタフェース内 WorkerBase
  - setMaximumPollRatePerSecond
```
public void setMaximumPollRatePerSecond(double maximumPollRatePerSecond)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Maximum number of poll request to the task list per second allowed. Default is 0 which means unlimited.
    
    定義:
    
    setMaximumPollRatePerSecond インタフェース内 WorkerBase
    
    関連項目:
    WorkerBase.setMaximumPollRateIntervalMilliseconds(int)
  - getMaximumPollRateIntervalMilliseconds
```
public int getMaximumPollRateIntervalMilliseconds()
```
    定義:
    
    getMaximumPollRateIntervalMilliseconds インタフェース内 WorkerBase
  - setMaximumPollRateIntervalMilliseconds
```
public void setMaximumPollRateIntervalMilliseconds(int maximumPollRateIntervalMilliseconds)
```
    インタフェースからコピーされた説明: WorkerBase
    
    The sliding window interval used to measure the poll rate. Controls allowed rate burstiness. For example if allowed rate is 10 per second and poll rate interval is 100 milliseconds the poller is not going to allow more then one poll per 100 milliseconds. If poll rate interval is 10 seconds then 100 request can be emitted as fast as possible, but then the polling stops until 10 seconds pass.
    
    定義:
    
    setMaximumPollRateIntervalMilliseconds インタフェース内 WorkerBase
    
    関連項目:
    WorkerBase.setMaximumPollRatePerSecond(double)
  - getIdentity
```
public java.lang.String getIdentity()
```
    定義:
    
    getIdentity インタフェース内 WorkerBase
  - setIdentity
```
public void setIdentity(java.lang.String identity)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Set the identity that worker specifies in the poll requests. This value ends up stored in the identity field of the corresponding Start history event. Default is "pid"@"host".
    
    定義:
    
    setIdentity インタフェース内 WorkerBase
    
    パラメータ:
    identity - maximum size is 256 characters.
  - getUncaughtExceptionHandler
```
public java.lang.Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()
```
    定義:
    
    getUncaughtExceptionHandler インタフェース内 WorkerBase
  - setUncaughtExceptionHandler
```
public void setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler uncaughtExceptionHandler)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Handler notified about poll request and other unexpected failures. The default implementation logs the failures using ERROR level.
    
    定義:
    
    setUncaughtExceptionHandler インタフェース内 WorkerBase
  - getPollBackoffInitialInterval
```
public long getPollBackoffInitialInterval()
```
    定義:
    
    getPollBackoffInitialInterval インタフェース内 WorkerBase
  - setPollBackoffInitialInterval
```
public void setPollBackoffInitialInterval(long backoffInitialInterval)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Failed poll requests are retried after an interval defined by an exponential backoff algorithm. See BackoffThrottler for more info.
    
    定義:
    
    setPollBackoffInitialInterval インタフェース内 WorkerBase
    
    パラメータ:
    backoffInitialInterval - the interval between failure and the first retry. Default is 100.
  - getPollBackoffMaximumInterval
```
public long getPollBackoffMaximumInterval()
```
    定義:
    
    getPollBackoffMaximumInterval インタフェース内 WorkerBase
  - setPollBackoffMaximumInterval
```
public void setPollBackoffMaximumInterval(long backoffMaximumInterval)
```
    定義:
    
    setPollBackoffMaximumInterval インタフェース内 WorkerBase
    
    パラメータ:
    backoffMaximumInterval - maximum interval between poll request retries. Default is 60000 (one minute).
    関連項目:
    WorkerBase.setPollBackoffInitialInterval(long)
  - getPollBackoffCoefficient
```
public double getPollBackoffCoefficient()
```
    定義:
    
    getPollBackoffCoefficient インタフェース内 WorkerBase
  - setPollBackoffCoefficient
```
public void setPollBackoffCoefficient(double backoffCoefficient)
```
    定義:
    
    setPollBackoffCoefficient インタフェース内 WorkerBase
    
    パラメータ:
    backoffCoefficient - coefficient that defines how fast retry interval grows in case of poll request failures. Default is 2.0.
    関連項目:
    WorkerBase.setPollBackoffInitialInterval(long)
  - getPollThreadCount
```
public int getPollThreadCount()
```
    定義:
    
    getPollThreadCount インタフェース内 WorkerBase
  - setPollThreadCount
```
public void setPollThreadCount(int threadCount)
```
    インタフェースからコピーされた説明: WorkerBase
    
    Defines how many concurrent threads are used by the given worker to poll the specified task list. Default is 1. Note that in case of ActivityWorker two separate threads pools are used. One for polling and another one for executing activities. The size of the activity execution thread pool is defined through ActivityWorker.setTaskExecutorThreadPoolSize(int).
    
    定義:
    
    setPollThreadCount インタフェース内 WorkerBase
  - getTaskExecutorThreadPoolSize
```
public int getTaskExecutorThreadPoolSize()
```
  - setTaskExecutorThreadPoolSize
```
public void setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize)
```
  - isDisableServiceShutdownOnStop
```
public boolean isDisableServiceShutdownOnStop()
```
    定義:
    
    isDisableServiceShutdownOnStop インタフェース内 WorkerBase
  - setDisableServiceShutdownOnStop
```
public void setDisableServiceShutdownOnStop(boolean disableServiceShutdownOnStop)
```
    インタフェースからコピーされた説明: WorkerBase
    
    When set to false (which is default) at the beginning of the worker shutdown AmazonSimpleWorkflow.shutdown() is called. It causes all outstanding long poll request to disconnect. But also causes all future request (for example activity completions) to SWF fail.
    
    定義:
    
    setDisableServiceShutdownOnStop インタフェース内 WorkerBase
  - suspendPolling
```
public void suspendPolling()
```
    インタフェースからコピーされた説明: Suspendable
    
    Do not make new poll requests. Outstanding long polls still can return tasks after this method was called.
    
    定義:
    
    suspendPolling インタフェース内 Suspendable
  - resumePolling
```
public void resumePolling()
```
    インタフェースからコピーされた説明: Suspendable
    
    Allow new poll requests.
    
    定義:
    
    resumePolling インタフェース内 Suspendable
  - start
```
public void start()
```
    定義:
    
    start インタフェース内 WorkerLifecycle
    
    定義:
    
    start インタフェース内 org.springframework.context.Lifecycle
  - stopNow
```
public void stopNow()
```
  - shutdown
```
public void shutdown()
```
    定義:
    
    shutdown インタフェース内 WorkerLifecycle
  - shutdownNow
```
public void shutdownNow()
```
    定義:
    
    shutdownNow インタフェース内 WorkerLifecycle
  - shutdownAndAwaitTermination
```
public boolean shutdownAndAwaitTermination(long timeout,
                                  java.util.concurrent.TimeUnit unit)
                                    throws java.lang.InterruptedException
```
    定義:
    
    shutdownAndAwaitTermination インタフェース内 WorkerLifecycle
    
    例外:
    
    java.lang.InterruptedException
  - awaitTermination
```
public boolean awaitTermination(long timeout,
                       java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException
```
    定義:
    
    awaitTermination インタフェース内 WorkerLifecycle
    
    例外:
    
    java.lang.InterruptedException
  - stop
```
public void stop()
```
    定義:
    
    stop インタフェース内 org.springframework.context.Lifecycle
  - isRunning
```
public boolean isRunning()
```
    定義:
    
    isRunning インタフェース内 WorkerBase
    
    定義:
    
    isRunning インタフェース内 org.springframework.context.Lifecycle
  - setActivitiesImplementations
```
public void setActivitiesImplementations(java.lang.Iterable<java.lang.Object> activitiesImplementations)
                                  throws java.lang.InstantiationException,
                                         java.lang.IllegalAccessException,
                                         java.lang.SecurityException,
                                         java.lang.NoSuchMethodException
```
    例外:
    
    java.lang.InstantiationException
    
    java.lang.IllegalAccessException
    
    java.lang.SecurityException
    
    java.lang.NoSuchMethodException
  - getActivitiesImplementations
```
public java.lang.Iterable<java.lang.Object> getActivitiesImplementations()
```
  - addActivitiesImplementation
```
public java.util.List<ActivityType> addActivitiesImplementation(java.lang.Object activitiesImplementation)
                                                         throws java.lang.InstantiationException,
                                                                java.lang.IllegalAccessException,
                                                                java.lang.SecurityException,
                                                                java.lang.NoSuchMethodException
```
    例外:
    
    java.lang.InstantiationException
    
    java.lang.IllegalAccessException
    
    java.lang.SecurityException
    
    java.lang.NoSuchMethodException
  - registerTypesToPoll
```
public void registerTypesToPoll()
```
    インタフェースからコピーされた説明: WorkerBase
    
    Try to register every type (activity or workflow depending on worker) that are configured with the worker.
    
    定義:
    
    registerTypesToPoll インタフェース内 WorkerBase
    
    関連項目:
    WorkerBase.setDisableTypeRegistrationOnStart(boolean)
  - getPhase
```
public int getPhase()
```
    定義:
    
    getPhase インタフェース内 org.springframework.context.Phased
    
    戻り値:
    default is 0
  - setPhase
```
public void setPhase(int startPhase)
```
  - isAutoStartup
```
public boolean isAutoStartup()
```
    定義:
    
    isAutoStartup インタフェース内 org.springframework.context.SmartLifecycle
  - getTerminationTimeoutSeconds
```
public long getTerminationTimeoutSeconds()
```
  - setTerminationTimeoutSeconds
```
public void setTerminationTimeoutSeconds(long terminationTimeoutSeconds)
```
  - isDisableAutoStartup
```
public boolean isDisableAutoStartup()
```
  - setDisableAutoStartup
```
public void setDisableAutoStartup(boolean disableAutoStartup)
```
  - setDisableTypeRegistrationOnStart
```
public void setDisableTypeRegistrationOnStart(boolean disableTypeRegistrationOnStart)
```
    インタフェースからコピーされた説明: WorkerBase
    
    When set to true disables types registration on start even if SkipTypeRegistration is not specified. Types still can be registered by calling WorkerBase.registerTypesToPoll().
    
    定義:
    
    setDisableTypeRegistrationOnStart インタフェース内 WorkerBase
  - isDisableTypeRegistrationOnStart
```
public boolean isDisableTypeRegistrationOnStart()
```
    定義:
    
    isDisableTypeRegistrationOnStart インタフェース内 WorkerBase
  - stop
```
public void stop(java.lang.Runnable callback)
```
    定義:
    
    stop インタフェース内 org.springframework.context.SmartLifecycle
  - toString
```
public java.lang.String toString()
```
    オーバーライド:
    
    toString クラス内 java.lang.Object

クラス SpringActivityWorker

コンストラクタの概要

メソッドの概要

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

コンストラクタの詳細

SpringActivityWorker

SpringActivityWorker

メソッドの詳細

getService

setService

getDomain

setDomain

isRegisterDomain

setRegisterDomain

getDomainRetentionPeriodInDays

setDomainRetentionPeriodInDays

getTaskListToPoll

setTaskListToPoll

getDataConverter

setDataConverter

getMaximumPollRatePerSecond

setMaximumPollRatePerSecond

getMaximumPollRateIntervalMilliseconds

setMaximumPollRateIntervalMilliseconds

getIdentity

setIdentity

getUncaughtExceptionHandler

setUncaughtExceptionHandler

getPollBackoffInitialInterval

setPollBackoffInitialInterval

getPollBackoffMaximumInterval

setPollBackoffMaximumInterval

getPollBackoffCoefficient

setPollBackoffCoefficient

getPollThreadCount

setPollThreadCount

getTaskExecutorThreadPoolSize

setTaskExecutorThreadPoolSize

isDisableServiceShutdownOnStop

setDisableServiceShutdownOnStop

suspendPolling

resumePolling

start

stopNow

shutdown

shutdownNow

shutdownAndAwaitTermination

awaitTermination

stop

isRunning

setActivitiesImplementations

getActivitiesImplementations

addActivitiesImplementation

registerTypesToPoll

getPhase

setPhase

isAutoStartup

getTerminationTimeoutSeconds

setTerminationTimeoutSeconds

isDisableAutoStartup

setDisableAutoStartup

setDisableTypeRegistrationOnStart

isDisableTypeRegistrationOnStart

stop

toString