README.md

Arena - WorkerManager

• Listens to any MQTT message on the topic ${mqtt.topic} from BaSyx, when it arrives, do:
  • Instantiates a new Camunda Worker for the specific device capability.
    • For each OperationSE with a qualifer (matched-qualifier) of type ${basyx.qualifierSkillProvider} do:
      • Instantiate a REST camunda worker of id matched-qualifier::value

sequenceDiagram
    participant MQTT-Broker
    participant WorkerManager
    participant BaSyx
    participant BPMNEngine as BPMN Engine
    
    MQTT-Broker ->> WorkerManager: Message Arrives at topic ${mqtt.topic}
    activate WorkerManager
    WorkerManager ->> BaSyx: Query for OperationSE with a qualifier of type ${basyx.qualifierSkillProvider}   
    activate BaSyx
    BaSyx -->> WorkerManager: result
    deactivate BaSyx
    WorkerManager ->> WorkerManager: Filter for skillProviders
    activate WorkerManager
    WorkerManager ->> BPMNEngine: Instantiate workers based on matched-qualifier::value [if not present]
    activate BPMNEngine
    deactivate BPMNEngine
    deactivate WorkerManager 
    deactivate WorkerManager

Loading

Requirements

• It shall react to changes in the AAS. E.g.:
  • If the target AAS is deleted, the camunda worker shall be stopped
  • If the job type changes, the worker shall be restarted with a new job

Configuring

An example configuration file is found at the example/scenario-demo-1. All relevant properties can be easily changed there, e.g. MQTT, Zeebe, BaSyx.

property	defaultValue	description
server.port	8111	Port to start the service
mqtt.hostname	-	MQTT Broker hostname
mqtt.port	-	MQTT Broker port
mqtt.username	-	MQTT Broker username
mqtt.password	-	MQTT Broker password
mqtt.topic	-	MQTT topic to listen to
mqtt.clientId	workermanager	Client ID for the MQTT connection
basyx.aasRegistryUrl	-	AasRegistry base endpoint
basyx.aasRepositoryUrl	-	AasRepository base endpoint
basyx.submodelRegistryUrl	-	SubmodelRegistry base endpoint
basyx.submodelRepositoryUrl	-	SubmodelRepository base endpoint
basyx.qualifierSkillProvider	skill-provider	OperationSE qualifier for skill providers
camunda.zeebeGateway	-	Zeebe gRPC endpoint