Implement your BPMN Service Task in NodeJS.
NodeJS >= v8.9.4 is required
npm install -s camunda-external-task-client-js
Or:
yarn add camunda-external-task-client-js
- Make sure to have Camunda running.
- Create a simple process model with an External Service Task and define the topic as 'topicName'.
- Deploy the process to the Camunda BPM engine.
- In your NodeJS script:
const { Client, logger } = require("camunda-external-task-client-js");
// configuration for the Client:
// - 'baseUrl': url to the Workflow Engine
// - 'logger': utility to automatically log important events
const config = { baseUrl: "https://localhost:8080/engine-rest", use: logger };
// create a Client instance with custom configuration
const client = new Client(config);
// susbscribe to the topic: 'creditScoreChecker'
client.subscribe("creditScoreChecker", async function({ task, taskService }) {
// Put your business logic
// complete the task
await taskService.complete(task);
});
Note: Although the examples used in this documentation use async await for handling asynchronous calls, you can also use Promises to achieve the same results.
External Tasks are service tasks whose execution differs particularly from the execution of other service tasks (e.g. Human Tasks). The execution works in a way that units of work are polled from the engine before being completed.
camunda-external-task-client.js allows you to create easily such client in NodeJS.
Done through polling.
// Susbscribe to the topic: 'topicName'
client.subscribe("topicName", async function({ task, taskService }) {
// Put your business logic
// Complete the task
await taskService.complete(task);
});
// Susbscribe to the topic: 'topicName'
client.subscribe("topicName", async function({ task, taskService }) {
// Put your business logic
// Handle a Failure
await taskService.handleFailure(task, "some failure message");
});
// Susbscribe to the topic: 'topicName'
client.subscribe("topicName", async function({ task, taskService }) {
// Put your business logic
// Handle a BPMN Failure
await taskService.handleBpmnError(task, "BPMNError_Code");
});
// Susbscribe to the topic: 'topicName'
client.subscribe("topicName", async function({ task, taskService }) {
// Put your business logic
// Extend the lock time
await taskService.extendLock(task, 5000);
});
// Susbscribe to the topic: 'topicName'
client.subscribe("topicName", async function({ task, taskService }) {
// Put your business logic
// Unlock the task
await taskService.unlock(task);
});
const { Variables } = require("camunda-external-task-client-js");
client.subscribe("topicName", async function({ task, taskService }) {
// get the process variable 'score'
const score = task.variables.get("score");
// set a process variable 'winning'
const processVariables = new Variables();
processVariables.set("winning", score > 5);
// set a local variable 'winningDate'
const localVariables = new Variables();
localVariables.set("winningDate", new Date());
// complete the task
await taskService.complete(task, processVariables, localVariables);
});
Unless otherwise specified this project is licensed under Apache License Version 2.0.