org.apache.camel.component.aws.swf
Class CamelSWFWorkflowClient

java.lang.Object
  org.apache.camel.component.aws.swf.CamelSWFWorkflowClient

public class CamelSWFWorkflowClient
extends Object

Constructor Summary

CamelSWFWorkflowClient(SWFEndpoint endpoint, SWFConfiguration configuration)

Method Summary

Map<String,Object>	describeWorkflowInstance(String workflowId, String runId)
List<com.amazonaws.services.simpleworkflow.model.HistoryEvent>	getWorkflowExecutionHistory(String workflowId, String runId)
Object	getWorkflowExecutionState(String workflowId, String runId, Class aClass)
void	requestCancelWorkflowExecution(String workflowId, String runId)
void	signalWorkflowExecution(String workflowId, String runId, String signalName, Object arguments)
String[]	startWorkflowExecution(String workflowId, String runId, String eventName, String version, Object arguments)
void	terminateWorkflowExecution(String workflowId, String runId, String reason, String details, String childPolicy)

Methods inherited from class java.lang.Object

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

Constructor Detail

CamelSWFWorkflowClient

public CamelSWFWorkflowClient(SWFEndpoint endpoint,
                              SWFConfiguration configuration)

Method Detail

signalWorkflowExecution

public void signalWorkflowExecution(String workflowId,
                                    String runId,
                                    String signalName,
                                    Object arguments)

getWorkflowExecutionState

public Object getWorkflowExecutionState(String workflowId,
                                        String runId,
                                        Class aClass)
                                 throws Throwable

Throws:

Throwable

requestCancelWorkflowExecution

public void requestCancelWorkflowExecution(String workflowId,
                                           String runId)

terminateWorkflowExecution

public void terminateWorkflowExecution(String workflowId,
                                       String runId,
                                       String reason,
                                       String details,
                                       String childPolicy)

startWorkflowExecution

public String[] startWorkflowExecution(String workflowId,
                                       String runId,
                                       String eventName,
                                       String version,
                                       Object arguments)

describeWorkflowInstance

public Map<String,Object> describeWorkflowInstance(String workflowId,
                                                   String runId)

getWorkflowExecutionHistory

public List<com.amazonaws.services.simpleworkflow.model.HistoryEvent> getWorkflowExecutionHistory(String workflowId,
                                                                                                  String runId)