Skip to content
Camunda External Task Worker that leverages Vert.x polyglot multi-language capabilities
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
camunda
docs
worker
LICENSE
README.md
docker-compose.yml

README.md

Camunda Worker (Vertx)

A CamundaBPM external task worker that offers polyglot event-driven workers with features such as: Auto-Fail-Over, High Availability, Clustering, Multiple Threads and Multi-Core Support, Polyglot language support for: Javascript(with NPM package support), Java, Groovy, Ruby, Scala, Kotlin, and Ceylon.

The worker is based on Vert.x (vertx.io) and is being bootstrapped with Nashorn/Javascript (other bootstrap languages can be used if you choose).

The benefits of a polyglot worker allows mult-language workers to be created without having to re-program the core interactions of Camunda external tasks.

This worker is a demo worker for showing the potential of Vertx as a External Task worker, and establishes some core use cases and configurations options.

TL;DR: Take me to how to use it

Updates

  1. For Ruby Gem / Gemfile resolution (automatically download gemfile Gem dependencies during docker build) see:
    1. .rb file: https://github.com/DigitalState/camunda-worker-vertx/blob/feature-ruby-rubygems-stackmanager/worker/verticles/ruby-biz/ruby-biz.rb
    2. gemfile: https://github.com/DigitalState/camunda-worker-vertx/blob/feature-ruby-rubygems-stackmanager/worker/Gemfile
    3. dockerfile: https://github.com/DigitalState/camunda-worker-vertx/blob/feature-ruby-rubygems-stackmanager/worker/Dockerfile

How it works

Overall, docker-compose deploys the camunda service (CamundaBPM) and the cam-worker_01 service (Vertx instance). Vert.x is deployed in a Docker container running vertx/vertx3-alpine which is Linux Alpine with the JVM. Camunda is deployed in a Docker container. running camunda/camunda-bpm-platform:tomcat-7.8.0: A JVM with Tomcat 8 running CamundaBPM 7.8.0. The two services share the name network through docker-compose.

Screenshots and Reference examples

BPMN

bpmn

See the camunda-deployment folder for CURL statement and BPMN file of test BPMN file that was used.

Camunda Modeler Configuration

external task config external task num1 external task num2

Camunda Cockpit

Cockpit Overview - No active tasks

Cockpit with Active External Task

Cockput with External Task details

Cockpit with completed external task

Console Output

cam-worker_01_1  | get-tasks received: go get some external tasks
cam-worker_01_1  | Received response with status code200
cam-worker_01_1  | Array Item count: 1
cam-worker_01_1  | Item: {"activityId":"Task_01axjwb","activityInstanceId":"Task_01axjwb:c58173d9-1675-11e8-986e-0242ac120003","errorMessage":null,"errorDetails":null,"executionId":"c58173d8-1675-11e8-986e-0242ac120003","id":"c581c1ff-1675-11e8-986e-0242ac120003","lockExpirationTime":"2018-02-20T14:50:21.755-0500","processDefinitionId":"externalTaskTest:1:a8f0384f-1675-11e8-986e-0242ac120003","processDefinitionKey":"externalTaskTest","processInstanceId":"c580fea6-1675-11e8-986e-0242ac120003","retries":null,"suspended":false,"workerId":"myWorkerId","topicName":"calculate-numbers","tenantId":null,"variables":{"num1":{"type":"String","value":"123","valueInfo":{}},"num2":{"type":"String","value":"321","valueInfo":{}}},"priority":0}
cam-worker_01_1  | Completed processing array
cam-worker_01_1  | calculate-numbers received: {"activityId":"Task_01axjwb","activityInstanceId":"Task_01axjwb:c58173d9-1675-11e8-986e-0242ac120003","errorMessage":null,"errorDetails":null,"executionId":"c58173d8-1675-11e8-986e-0242ac120003","id":"c581c1ff-1675-11e8-986e-0242ac120003","lockExpirationTime":"2018-02-20T14:50:21.755-0500","processDefinitionId":"externalTaskTest:1:a8f0384f-1675-11e8-986e-0242ac120003","processDefinitionKey":"externalTaskTest","processInstanceId":"c580fea6-1675-11e8-986e-0242ac120003","retries":null,"suspended":false,"workerId":"myWorkerId","topicName":"calculate-numbers","tenantId":null,"variables":{"num1":{"type":"String","value":"123","valueInfo":{}},"num2":{"type":"String","value":"321","valueInfo":{}}},"priority":0}
cam-worker_01_1  | numbers: 123 and 321
cam-worker_01_1  | task-complete received: {"source":{"activityId":"Task_01axjwb","activityInstanceId":"Task_01axjwb:c58173d9-1675-11e8-986e-0242ac120003","errorMessage":null,"errorDetails":null,"executionId":"c58173d8-1675-11e8-986e-0242ac120003","id":"c581c1ff-1675-11e8-986e-0242ac120003","lockExpirationTime":"2018-02-20T14:50:21.755-0500","processDefinitionId":"externalTaskTest:1:a8f0384f-1675-11e8-986e-0242ac120003","processDefinitionKey":"externalTaskTest","processInstanceId":"c580fea6-1675-11e8-986e-0242ac120003","retries":null,"suspended":false,"workerId":"myWorkerId","topicName":"calculate-numbers","tenantId":null,"variables":{"num1":{"type":"String","value":"123","valueInfo":{}},"num2":{"type":"String","value":"321","valueInfo":{}}},"priority":0},"result":444}
cam-worker_01_1  | Received response with status code204
cam-worker_01_1  | Camunda Task Completion Response:null

Vertx Instance

The Vertx instance, named: cam-worker_01 in the docker-compose file, and camunda-worker in Vertx configurations.

The goal of this project was to us Javascript/nashorn language is used for all aspects, including bootstrap of the Vertx instance. Other languages could be used, but it was to test configuration and use case opportunities against the Node Camunda External task worker: https://github.com/nikku/camunda-worker-node

The great part is that we can easily use other languages with the same Vertx instance such as:

  1. Java
  2. Groovy
  3. Ruby
  4. Ceylon
  5. Scala
  6. Kotlin

See Vertx.io for more information.

Verticles

camunda-worker.js

Establishes the primary verticle that deploys the other verticles. Also has a example of accessing the config.json file that is deployed.

Source

fetch-and-lock.js

Fetches Camunda external tasks from Camunda External Tasks using the defined configuration

Source

calculate-numbers.js

Catches data from the event bus and runs a calculation (addition of two numbers) and sends it to the task-complete verticle

Source

task-complete.js

Completes the external task with the result provided by the calculate-numbers verticle.

Source

http-server.js

A web server that exposes the localhost:8081/get-tasks endpoint, which will trigger the fetch-tasks verticle.

Source

Camunda Instance

The camunda instance is a basic deployment of the Camunda Docker container: https://github.com/camunda/docker-camunda-bpm-platform, using Tomcat and Camunda BPM 7.8.0.

Camunda Web Apps: localhost:8055/camunda/ Camunda REST API: localhost:8055/engine-rest/

How to Use it

  1. Open terminal into root of repo: run docker-compose up --build
  2. It will take a few seconds for camundaBPM and Vertx to startup. Watch the terminal for progress.
  3. deploy the BPMN file to camunda (localhost:8055/engine-rest). See the CURL statement and BPMN file
  4. Through the Camunda tasklist (localhost:8055/camunda/app/tasklist), start an instance of the process "External Task Test". You should see a running instance afterwards in the Camunda Cockpit.
  5. In your browser go to: localhost:8081/get-tasks. This is the Vertx server route that will tell vertx instance to check camunda for tasks.

Project Notes

This is a growing list of project notes and considerations

  1. Exponential Backoff needs to be implemented in the Fetch and Lock verticle.
  2. A timer needs to be added to the Fetch and Lock allowing timed capture. Only new tasks should be gotten if there are not active tasks.
  3. Further configuration options for task fetch and task completion need to be added. This was just a initial demonstration.
  4. See the Fetch and Lock verticle for a example of how Arrays are iterated through
  5. Vertx returns most objects as JS Objects rather than the typical Nashorn mirror objects
  6. See the Vertx dockerfile for the CMD line that executes the vertx run command. This command is what activates the Vertx instance which is accessible in the camunda-worker.js verticle.
  7. To enable High Availability (-ha) see the Docker-Compose file and the cluster.xml. You can easily test -ha by enabling it in the docker-compose file, and then generating a vertx run -ha service in the docker-compose file.
  8. the Vertx dockerfile expects several files for deployment.
  9. The Vertx Stack Manager is used to download Maven dependencies. See the verxt-stack.json file.
  10. See the fetch-and-lock verticle for example of using NPM modules and using require() in the JS files.
You can’t perform that action at this time.
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session.