SuperAPI AI 工具集

publish-nats-message

智能体与模型

查看项目

更新于 10-16 01:35

技能介绍

用途:让相互协作的项目按跨团队契约正确生产消息,通过 NATS MCP 工具发布一条对齐 specs/nats-messaging.md 的 subject、headers、payload、QoS 的消息;某事件首次无契约时先引导生成契约并落盘 producer repo。

主要能力:读取项目缓存 .cortex/nats.yaml;按事件 Glob 定位 <event>-contract.md;缺契约时按 specs/nats-messaging.md 与 specs/cross-team-contract.md 起草契约;构造合规消息并校验 payload 字段;按 QoS 调用 mcp__nats__publish(at-most-once)、mcp__nats__jetstream_publish(at-least-once,等 ack)、mcp__nats__request(同步请求-响应);失败按契约策略重试并复用同一 Nats-Msg-Id,达 max_deliver 仍失败则上报。

必要用法:已连接 NATS MCP server,当前工作目录为 producer repo,用户可授权发布权限。流程为宣告、读缓存、定位契约、必要时起草并等待用户确认、构造并校验消息、按 QoS 发送、自检与回执。Nats-Msg-Id 为生成的 UUID v7;重试复用原 ID;元信息走 Headers 而非 payload。

适用场景:跨团队事件发布、多轮会话消息、同步请求-响应、telemetry 或心跳等。

限制:不负责写 publisher 代码,不创建或修改 JetStream stream、consumer、KV(属 IaC),不负责订阅消费(用 consume-nats-message)。具体工具名以连接的 MCP server 为准;官方 NATS 行为以 docs.nats.io 为准。缓存或契约缺失时按子流程处理。缓存字段、契约目录、重试默认值等以资料描述为准。