public class SynchronousActivityWorker extends Object
Constructor and Description |
---|
SynchronousActivityWorker() |
SynchronousActivityWorker(AmazonSimpleWorkflow service,
String domain,
String taskListToPoll) |
public SynchronousActivityWorker()
public SynchronousActivityWorker(AmazonSimpleWorkflow service, String domain, String taskListToPoll)
public boolean pollAndProcessSingleActivityTask() throws Throwable
Throwable
public void setActivitiesImplementations(Iterable<Object> activitiesImplementations) throws InstantiationException, IllegalAccessException, SecurityException, NoSuchMethodException
public List<ActivityType> addActivitiesImplementations(Iterable<Object> activitiesImplementations) throws InstantiationException, IllegalAccessException, SecurityException, NoSuchMethodException
public List<ActivityType> addActivitiesImplementations(Iterable<Object> activitiesImplementations, DataConverter dataConverter) throws InstantiationException, IllegalAccessException, SecurityException, NoSuchMethodException
public List<ActivityType> addActivitiesImplementation(Object activitiesImplementation) throws InstantiationException, IllegalAccessException, SecurityException, NoSuchMethodException
public List<ActivityType> addActivitiesImplementation(Object activitiesImplementation, DataConverter converter) throws InstantiationException, IllegalAccessException, SecurityException, NoSuchMethodException
public Iterable<ActivityType> getActivityTypesToRegister()
public ActivityImplementation getActivityImplementation(ActivityType activityType)
public AmazonSimpleWorkflow getService()
public void setService(AmazonSimpleWorkflow service)
public String getDomain()
public void setDomain(String domain)
public String getPollTaskList()
public void setTaskListToPoll(String taskList)
public String getIdentity()
public void setIdentity(String identity)
public ExponentialRetryParameters getReportCompletionRetryParameters()
public void setReportCompletionRetryParameters(ExponentialRetryParameters reportCompletionRetryParameters)
public ExponentialRetryParameters getReportFailureRetryParameters()
public void setReportFailureRetryParameters(ExponentialRetryParameters reportFailureRetryParameters)
public String getTaskListToPoll()