...
A workflow producer allows interacting with a workflow. It can start a new workflow execution, query its state, send signals to a running workflow, or terminate and cancel it.
Div |
---|
class | confluenceTableSmall |
---|
|
Header | Type | Description |
---|
CamelSWFOperation
| String
| The operation to perform on the workflow. Supported operations are: SIGNAL, CANCEL, TERMINATE, GET_STATE, START, DESCRIBE, GET_HISTORY. | CamelSWFWorkflowId
| String
| A workflow ID to use. | CamelAwsDdbKeyCamelSWFRunId
| String
| A worfklow run ID to use. | CamelSWFStateResultType
| String
| The type of the result when a workflow state is queried. | CamelSWFEventName
| String
| The workflow or activity event name to use. | CamelSWFVersion
| String
| The workflow or activity event version to use. | CamelSWFReason
| String
| The reason for terminating a workflow. | CamelSWFDetails
| String
| Details for terminating a workflow. | CamelSWFChildPolicy
| String
| The policy to use on child workflows when terminating a workflow. | CamelSWFTags | List<String> | Camel 2.18.0 : Tags associated with a workflow execution which can be used later to query/filter executions in SWF console |
|
Wiki Markup |
---|
{div:class=confluenceTableSmall}
|| Header || Type || Description ||
| {{CamelSWFOperation}} | {{String}} | The operation to perform on the workflow. Supported operations are:
SIGNAL, CANCEL, TERMINATE, GET_STATE, START, DESCRIBE, GET_HISTORY. |
| {{CamelSWFWorkflowId}} | {{String}} | A workflow ID to use. |
| {{CamelAwsDdbKeyCamelSWFRunId}} | {{String}} | A worfklow run ID to use. |
| {{CamelSWFStateResultType}} | {{String}} | The type of the result when a workflow state is queried. |
| {{CamelSWFEventName}} | {{String}} | The workflow or activity event name to use. |
| {{CamelSWFVersion}} | {{String}} | The workflow or activity event version to use. |
| {{CamelSWFReason}} | {{String}} | The reason for terminating a workflow. |
| {{CamelSWFDetails}} | {{String}} | Details for terminating a workflow. |
| {{CamelSWFChildPolicy}} | {{String}} | The policy to use on child workflows when terminating a workflow. |
{div} |
Div |
---|
class | confluenceTableSmall |
---|
|
Header | Type | Description |
---|
CamelSWFWorkflowId
| String
| The worfklow ID used or newly generated. | CamelAwsDdbKeyCamelSWFRunId
| String
| The worfklow run ID used or generated. |
|
Wiki Markup |
---|
{div:class=confluenceTableSmall}
|| Header || Type || Description ||
| {{CamelSWFWorkflowId}} | {{String}} | The worfklow ID used or newly generated. |
| {{CamelAwsDdbKeyCamelSWFRunId}} | {{String}} | The worfklow run ID used or generated. |
{div} |
A workflow consumer represents the workflow logic. When it is started, it will start polling workflow decision tasks and process them. In addition to processing decision tasks, a workflow consumer route, will also receive signals (send from a workflow producer) or state queries. The primary purpose of a workflow consumer is to schedule activity tasks for execution using activity producers. Actually activity tasks can be scheduled only from a thread started by a workflow consumer.
Div |
---|
class | confluenceTableSmall |
---|
|
Header | Type | Description |
---|
CamelSWFAction
| String
| Indicates what type is the current event: CamelSWFActionExecute, CamelSWFSignalReceivedAction or CamelSWFGetStateAction. | CamelSWFWorkflowReplaying
| boolean
| Indicates whether the current decision task is a replay or not. | CamelSWFWorkflowStartTime
| long
| The time of the start event for this decision task. |
|
Wiki Markup |
---|
{div:class=confluenceTableSmall}
|| Header || Type || Description ||
| {{CamelSWFAction}} | {{String}} | Indicates what type is the current event: CamelSWFActionExecute, CamelSWFSignalReceivedAction or CamelSWFGetStateAction. |
| {{CamelSWFWorkflowReplaying}} | {{boolean}} | Indicates whether the current decision task is a replay or not. |
| {{CamelSWFWorkflowStartTime}} | {{long}} | The time of the start event for this decision task. |
{div} |
An activity producer allows scheduling activity tasks. An activity producer can be used only from a thread started by a workflow consumer ie, it can process synchronous exchanges started by a workflow consumer.
Div |
---|
class | confluenceTableSmall |
---|
|
Wiki Markup |
---|
{div:class=confluenceTableSmall}
|| Header || Type || Description ||
| {{CamelSWFEventName}} | Header | Type | Description |
---|
CamelSWFEventName
|
| |
| {{CamelSWFVersion}} | {{String}} | The activity version to schedule. |
{div} | CamelSWFVersion
| String
| The activity version to schedule. |
|
Div |
---|
class | confluenceTableSmall |
---|
|
Header | Type | Description |
---|
CamelSWFTaskToken
| String
| The task token that is required to report task completion for manually completed tasks. |
|
Wiki Markup |
---|
{div:class=confluenceTableSmall}
|| Header || Type || Description ||
| {{CamelSWFTaskToken}} | {{String}} | The task token that is required to report task completion for manually completed tasks. |
{div} |
Advanced amazonSWClient configuration
...
Maven users will need to add the following dependency to their pom.xml.
Code Block |
---|
|
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws</artifactId>
<version>${camel-version}</version>
</dependency>
|
...