get_plan
先驗證憑證。成功代表 key 有效；治理類工具還需要 admin scope。
官方 MCP Server
讓 agent 直接發布、等待與治理事件。
不必先寫一層「事件轉 LLM」服務。MCP client 以 stdio 啟動 @msgmesh/mcp-server，模型即可發現 topic、訊息、Webhook、DLQ、用量與稽核工具。
步驟 1
把 Server 加進 MCP client。
以下格式適用於使用 mcpServers 設定的 client。把佔位字串連同尖括號一起換成面板 Keys 頁顯示一次的明文 key。
{
"mcpServers": {
"msgmesh": {
"command": "npx",
"args": ["-y", "@msgmesh/mcp-server"],
"env": {
"MQ_API_KEY": "<YOUR_API_KEY>"
}
}
}
}不要把 $MQ_API_KEY 當成會自動展開的 shell 變數；多數 MCP client 會原樣傳入。請填寫真實 key，並在修改後重啟 client。
步驟 2
用四個工具驗證第一條事件流。
create_topic
建立一個 topic，例如 orders。重複建立會回 409，所以這一步只做一次。
publish_message
發布任意 JSON 事件。發布端 key 至少需要該 topic 的 publish 能力。
watch_topic
以固定 consumer group 等待下一批；處理後使用同一個 group 再次呼叫，形成 watch → react → watch。
watch_topic 最長等待 55 秒；等待視窗內沒有事件會回空並提示繼續呼叫，不代表訂閱已經失效。
許可權選擇
不要為了方便把 admin key 給所有 agent。
| 要做的事 | 需要的能力 | 注意 |
|---|---|---|
| 發布或等待事件 | 對應 topic 的 publish／subscribe | 可用能力鍵把範圍縮到指定 topic；watch 不支援 room。 |
| 建立／刪除 topic、key、schema、Webhook | admin scope | 這些工具會改變狀態；讓 client 在執行前要求人工確認。 |
| 讀取用量與稽核 | admin scope | 不要在遇到 401／403 時讓 agent 自動重簽 key；應回到面板處理。 |
副作用
名字像查詢，不代表它是隻讀。
01
watch_topic
會提交 consumer group 位移，屬於 at-most-once。取回後若回應遺失，同一批不會再送一次。
02
consume_messages
有訊息就回、沒有就立即回空；同樣會推進位移，不適合當成無副作用的檢查。
03
dlq_peek
檢視死信也會推進 group；若要重複檢查，請設計明確的 group 與操作流程。
延伸閱讀
從連線成功走到正確執行。
建立 key，驗證 get_plan。
確認憑證與 scope 後，再讓 agent 建立 topic 或等待事件。