mq-consumer

为已有聚合新增 MQ 消费者入口（adapter 层 Consumer）。当需要接入消息驱动场景时使用。

安装方式

默认使用会先检查来源的 Prompt；你也可以切换为直接命令，或下载本地副本。

用 Codex 或 Claude 帮你安装复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。

直接命令不会经过审查 Prompt；运行前请先检查来源。

npx skills add https://github.com/yoursweakfoe/ywf-ddd-java --skill mq-consumer

命令会保持在同一行。复制前请横向滚动并检查完整内容。

想先保存到本地？可下载 SkillsMP 当前能够提供的文件。

决定是否安装前，请先阅读 SKILL.md，以及 SkillsMP 当前展示的配套文件。

SKILL.md

来源说明 · 只读预览

name	mq-consumer
description	为已有聚合新增 MQ 消费者入口（adapter 层 Consumer）。当需要接入消息驱动场景时使用。

adapter：创建 adapter/{agg}/consumer/{Event}Consumer.java
- @Component（MQ 监听注解待 common-mq 建设后补充）
- 构造器注入 {Agg}AppService
- 方法内：反序列化消息 → 构建 Command → 透传 AppService
- 禁止在 Consumer 内写业务逻辑
幂等性选择（三选一）：
- 状态机天然幂等：catch BusinessException → 判断 messageKey → 安全忽略重复
- 去重表：消费前 INSERT messageId（唯一键），冲突则跳过
- 乐观锁：version 保护，UPDATE 影响 0 行 → 忽略
contract（如需新 Command）：创建对应 Command 类
- 若复用已有 Command（如 PayOrderCommand），跳过此步
application（如需新 Handler）：按 new-usecase skill 创建
- 若复用已有 Handler，跳过此步