用途:在 Quarkus 项目中集成 ddd4j MQ 适配器,统一处理 Kafka、NATS 及当前维护线支持的其他 Broker,涵盖 ACK 确认、监听器、生命周期与 Testcontainers 测试。需先确定 3.3.x 或 4.0.x 维护线,再阅读对应源码。
主要能力:通过 CDI 注册 MQClients 与监听器,并明确 required/optional 语义;实现业务成功后 ack、按策略 nack 重入队、重试上限与死信;管理监听器生命周期,包括启动/关闭观察者、drain、逆序关闭与幂等关闭;用 Testcontainers 做发布/消费、消息头、ack/nack/重试、重复投递与恢复的往返测试。
使用方式:先确认目标维护线与源码,再按需选择 Broker 并注册客户端与监听器,随后实现可靠性与生命周期,最后用真实 Broker 测试并输出报告。安装命令:npx skills add full-stack-skills/ddd4j-skills --skill ddd4j-quarkus-mq。
适用场景:Quarkus 上的 ddd4j 消息集成、CDI 监听器注册、投递语义与生命周期审查。
限制:不适用于 Spring Boot 消息(用 ddd4j-boot-mq)、Spring Cloud Stream(用 ddd4j-cloud-stream)、Javalin 消息(用 ddd4j-javalin-mq)、领域事件发布契约(用 ddd4j-core)及无 Broker 语义的通用 CDI 装配(用 ddd4j-quarkus-runtime)。3.3.x 与 4.0.x 各有独立契约,4.0.x 不代表 Quarkus Platform 4。Docker 不可用时测试须标记 BLOCKED/SKIPPED,不得记为 PASS。缺少输入时输出 missing 提示。不访问或存储任何凭据。