public class DecisionTaskPoller extends Object implements TaskPoller
Constructor and Description |
---|
DecisionTaskPoller() |
DecisionTaskPoller(AmazonSimpleWorkflow service,
String domain,
String taskListToPoll,
DecisionTaskHandler decisionTaskHandler) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long left,
TimeUnit milliseconds) |
DecisionTaskHandler |
getDecisionTaskHandler() |
String |
getDomain() |
String |
getIdentity() |
AmazonSimpleWorkflow |
getService() |
String |
getTaskListToPoll() |
boolean |
pollAndProcessSingleTask()
Poll for a workflow task and call appropriate decider.
|
void |
setDecisionTaskHandler(DecisionTaskHandler decisionTaskHandler) |
void |
setDomain(String domain) |
void |
setIdentity(String identity) |
void |
setService(AmazonSimpleWorkflow service) |
void |
setTaskListToPoll(String pollTaskList) |
void |
shutdown() |
void |
shutdownNow() |
public DecisionTaskPoller()
public DecisionTaskPoller(AmazonSimpleWorkflow service, String domain, String taskListToPoll, DecisionTaskHandler decisionTaskHandler)
public String getIdentity()
public void setIdentity(String identity)
public AmazonSimpleWorkflow getService()
public String getDomain()
public DecisionTaskHandler getDecisionTaskHandler()
public void setDecisionTaskHandler(DecisionTaskHandler decisionTaskHandler)
public void setService(AmazonSimpleWorkflow service)
public void setDomain(String domain)
public String getTaskListToPoll()
public void setTaskListToPoll(String pollTaskList)
public boolean pollAndProcessSingleTask() throws Exception
pollAndProcessSingleTask
in interface TaskPoller
Exception
DeciderConfigurationException
public void shutdown()
shutdown
in interface TaskPoller
public void shutdownNow()
shutdownNow
in interface TaskPoller
public boolean awaitTermination(long left, TimeUnit milliseconds) throws InterruptedException
awaitTermination
in interface TaskPoller
InterruptedException