feat: Workflow Message Queue (WMQ) — push messages into running workflows#917

Closed

mp-orkes wants to merge 13 commits into

mainfrom

workflow/message-queue

Commits on Apr 1, 2026

Add Workflow Message Queue (WMQ) feature

mp-orkes
and
claude
committed
Fix spotless violations
mp-orkes
committed
Moved the WMQ docs to /docs/wmq
mp-orkes
committed
fix(wmq): remove redundant ConcurrentHashMap in InMemoryWorkflowMessageQueueDAO
mp-orkes
committed
fix(wmq): store defensive copy of payload in WorkflowMessage

mp-orkes
and
claude
committed
docs(wmq): document shallow immutability contract for WorkflowMessage.payload
mp-orkes
committed
fix(wmq): atomic pop/push via Lua scripts, fix TTL long-to-int cast
mp-orkes
committed
feat(wmq): delete per-workflow queue on workflow completion and termination

mp-orkes
and
claude
committed
fix(wmq): harden WorkflowMessageQueueResource

mp-orkes
and
claude
committed
feat(wmq): default conductor.workflow-message-queue.enabled to false

mp-orkes
and
claude
committed
chore(wmq): apply spotless formatting to all changed files

mp-orkes
and
claude
committed
PULL_WORKFLOW_MESSAGES - Non blocking
mp-orkes
committed
fix(wmq): apply spotless formatting to PullWorkflowMessagesTest
mp-orkes
committed