Operations Dashboard
Real-time pipeline health and staging review status
Loading stats…
Pipeline Flow
Warehouse processingstate counts
🔴 Failed: —
🟡 Transforming: —
🔵 Ingesting: —
Staging Status Summary
Quick Navigation
Data Warehouse
All raw ingestion events — processingstate machine
| Ref | Supplier | Source | Datatype | Filename | State | Received | Actions |
|---|---|---|---|---|---|---|---|
Loading… | |||||||
Ingestion Batches
Per-batch parse and row-level status
| ID | Ref | Supplier | Datatype | Status | Total Rows | Parsed Rows | Created | Actions |
|---|
Supplier Registry
Manage supplier config, sync mode and conflict strategy
| ID | Name | Code | Sync Mode | Conflict Strategy | Status | Created | Actions |
|---|
Field Mappings
Supplier field → EqomOS platform field per datatype
| Supplier Field | Platform Field | Datatype | Transform | Required | Default | Seq | Actions |
|---|
Value Mappings
Supplier vocabulary → EqomOS vocabulary (Levenshtein fuzzy matching)
| Field Name | Supplier Value | Platform Value | Platform Record ID | Datatype | Actions |
|---|
SKU Images
Supplier-provided SKU images — download status and storage tracking
| ID | Staging SKU ID | Supplier | Batch | Image URL | Status | Storage Key | Seq | Actions |
|---|
Audit Log
Immutable record of all pipeline actions
Filters
| ID | Supplier | Action | Datatype | Ref Table | Ref ID | Timestamp | Before/After |
|---|
Sync Log
Platform sync outcomes per staging record
| ID | Supplier | Datatype | Staging Table | Platform Table | Action | Status | Timestamp |
|---|
API Endpoints
Per-datatype REST endpoint configuration for REST_API / API_PULL / WEBHOOK suppliers
Showing active suppliers with sync mode: REST_API, API_PULL, WEBHOOK
Configured Endpoints
| On/Off | Datatype | Endpoint | Method | Pagination | Page Size | Frequency | Next Run | Incremental | Last Status | Actions |
|---|---|---|---|---|---|---|---|---|---|---|
Select a supplier to view endpoints… | ||||||||||
Bulk Field Mapping Upload
Upload up to 5,000 field mapping rows via XLSX template · Queue-safe · Supplier-scoped
Bulk Value Mapping Upload
Upload up to 5,000 value mapping rows via XLSX template · Queue-safe · Supplier-scoped
🐝 CamelBee Observability
Real-time route visualization, message tracing, metrics & debugging for all DMS Camel routes
🐝 CamelBee
v2.0.4 Spring Boot
Connected · EqomosDmsCamel
ROUTE STATUS
dms.warehouse.file (R0)
File poll → warehouse raw dump
SFTP+FS
dms.warehouse.webhook (R0)
API push → warehouse raw dump
HTTP
dms.ingestion (R1)
Raw → Batch, dedup, fingerprint
SEDA
dms.parse (R2)
Parse → Map → Stage → rowhash
SEDA
dms.sync (R3)
Staging → Platform DB sync
SEDA
dms.image.download (R4)
SKU image download queue
TIMER
CamelBee Integration Setup
The DMS Spring Boot app exposes CamelBee REST APIs at
/camelbee/**. Open the hosted React UI at camelbee.io, then configure the backend URL to http://<host>:8090.Maven Dependency
<dependency>
<groupId>io.camelbee</groupId>
<artifactId>camelbee-springboot-core</artifactId>
<version>2.0.4</version>
</dependency>
<groupId>io.camelbee</groupId>
<artifactId>camelbee-springboot-core</artifactId>
<version>2.0.4</version>
</dependency>
application.properties
camelbee.context-enabled=true
camelbee.notifier-enabled=true
camelbee.tracer-enabled=true
camelbee.route-configurer-enabled=true
camelbee.logging-enabled=true
camelbee.notifier-enabled=true
camelbee.tracer-enabled=true
camelbee.route-configurer-enabled=true
camelbee.logging-enabled=true
CamelBee Features Active in DMS
🗺️
Route Topology Visualization
Visual flow diagram of all 6 Camel routes with live exchange counts
🔬
Message Tracing & Replay
Trace individual messages. Replay failed messages from any checkpoint
📊
Real-time Metrics
Exchange counts, error rates, p95 latency, JVM heap/GC metrics
⚡
Endpoint Triggering
Concurrently invoke any consumer endpoint for load testing
🐛
Route Debugger
Pause, step, inspect Exchange headers and body at every processor
❤️
Health & Liveness
Spring Boot Actuator /health + Camel route liveness per routeId