Name	Name	Last commit message	Last commit date
parent directory ..
src	src
.gitignore	.gitignore
Dockerfile	Dockerfile
README.md	README.md
docker-compose.yml	docker-compose.yml
pom.xml	pom.xml
run.sh	run.sh

Name

Last commit message

Last commit date

Industrial Iot

Orchestrates industrial iot through a multi-stage Conductor workflow.

Input: plantId, machineId, machineType | Timeout: 60s

Pipeline

iit_monitor_machines
    │
iit_predictive_analysis
    │
iit_schedule_repair

MonitorMachinesWorker (iit_monitor_machines)

Reads telemetry. Outputs telemetry, temperature, vibration, pressure, rpm.

PredictiveAnalysisWorker (iit_predictive_analysis)

Reads failureProbability. Outputs failureProbability, predictedComponent, estimatedRemainingLife, modelConfidence.

ScheduleRepairWorker (iit_schedule_repair)

Reads repairScheduled. Outputs repairScheduled, workOrderId, scheduledDate, partsRequired, estimatedDowntime.

4 tests cover valid inputs, boundary values, null handling, and error paths.

mvn test

Run this example: see RUNNING.md for setup, build, and CLI instructions.