public class DecisionTaskPoller extends java.lang.Object implements TaskPoller
| コンストラクタと説明 |
|---|
DecisionTaskPoller() |
DecisionTaskPoller(AmazonSimpleWorkflow service,
java.lang.String domain,
java.lang.String taskListToPoll,
DecisionTaskHandler decisionTaskHandler) |
| 修飾子とタイプ | メソッドと説明 |
|---|---|
boolean |
awaitTermination(long left,
java.util.concurrent.TimeUnit milliseconds) |
protected void |
checkFieldNotNegative(java.lang.String fieldName,
long fieldValue) |
DecisionTaskHandler |
getDecisionTaskHandler() |
java.lang.String |
getDomain() |
java.lang.String |
getIdentity() |
AmazonSimpleWorkflow |
getService() |
java.lang.String |
getTaskListToPoll() |
boolean |
pollAndProcessSingleTask()
Poll for a workflow task and call appropriate decider.
|
void |
setDecisionTaskHandler(DecisionTaskHandler decisionTaskHandler) |
void |
setDomain(java.lang.String domain) |
void |
setIdentity(java.lang.String identity) |
void |
setService(AmazonSimpleWorkflow service) |
void |
setTaskListToPoll(java.lang.String pollTaskList) |
void |
shutdown() |
void |
shutdownNow() |
public DecisionTaskPoller()
public DecisionTaskPoller(AmazonSimpleWorkflow service, java.lang.String domain, java.lang.String taskListToPoll, DecisionTaskHandler decisionTaskHandler)
public java.lang.String getIdentity()
public void setIdentity(java.lang.String identity)
public AmazonSimpleWorkflow getService()
public java.lang.String getDomain()
public DecisionTaskHandler getDecisionTaskHandler()
public void setDecisionTaskHandler(DecisionTaskHandler decisionTaskHandler)
public void setService(AmazonSimpleWorkflow service)
public void setDomain(java.lang.String domain)
public java.lang.String getTaskListToPoll()
public void setTaskListToPoll(java.lang.String pollTaskList)
public boolean pollAndProcessSingleTask()
throws java.lang.Exception
pollAndProcessSingleTask インタフェース内 TaskPollerjava.lang.ExceptionDeciderConfigurationExceptionprotected void checkFieldNotNegative(java.lang.String fieldName,
long fieldValue)
throws java.lang.IllegalStateException
java.lang.IllegalStateExceptionpublic void shutdown()
shutdown インタフェース内 TaskPollerpublic void shutdownNow()
shutdownNow インタフェース内 TaskPollerpublic boolean awaitTermination(long left,
java.util.concurrent.TimeUnit milliseconds)
throws java.lang.InterruptedException
awaitTermination インタフェース内 TaskPollerjava.lang.InterruptedException