AgentSkillsCN

adapter-mq-consumer-generator

在适配器层生成调度任务，统一打包方式、批次配置，同时具备安全的重试机制。

SKILL.md
--- frontmatter
name: adapter-mq-consumer-generator
description: "Generates MQ consumers in adapter layer that use inbox idempotency and dispatch to app handlers safely."

Adapter MQ Consumer Generator

Follow .codex/skills/GENERATOR_SKILL_STRUCTURE.md.

Use For

  • •{{basePackage}}.adapter.mq.*

Inputs Required

  • •Topic + groupId + concurrency requirements
  • •Envelope format (headers/payload)
  • •Ack/retry strategy (framework defaults vs explicit)

Outputs

  • •.../adapter/mq/system/consumer/<XxxConsumer>.java (system) or .../adapter/mq/biz/consumer (BC)
  • •start YAML keys for topics/groups/concurrency

Naming & Packaging

  • •System consumers go under adapter.mq.system.consumer
  • •Keep consumer thin; delegate to app dispatcher

Implementation Rules

  • •Consumer should:
    • •deserialize envelope
    • •call EventDispatcher.dispatch(...)
    • •rely on inbox for idempotency
  • •Missing handler must not poison processing; ensure dispatcher marks inbox DEAD.

Reference Implementations

  • •{{adapterModuleDir}}/src/main/java/{{basePackagePath}}/adapter/mq/system/consumer/OutboxEventKafkaConsumer.java

Pitfalls

  • •Swallowing exceptions that should trigger framework retry (depends on retry strategy).