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

User Migration

Orchestrates user migration through a multi-stage Conductor workflow.

Input: sourceDb, targetDb, batchSize | Timeout: 60s

Pipeline

umg_extract
    │
umg_transform
    │
umg_load
    │
umg_verify
    │
umg_notify

ExtractWorker (umg_extract)

Reads sourceDb. Outputs users, extractedCount.

LoadWorker (umg_load)

Reads targetDb. Outputs loadedCount, failedCount.

NotifyMigrationWorker (umg_notify)

Outputs notified, channel.

TransformWorker (umg_transform)

Outputs transformed, transformedCount, fieldsAdded.

VerifyMigrationWorker (umg_verify)

boolean match = loaded != null && loaded.equals(expected);

Reads expected, loaded. Outputs allMatch, verificationResult.

12 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.