MsgMesh MCP server
Event bus for AI agents: watch_topic long-polls live events; manage topics, schemas, webhooks.
0 stars90 downloads/wk
Reviews
Write oneNobody has reviewed MsgMesh yet.
If you have run it, two minutes of your experience saves the next person an afternoon.
MsgMesh tools (29, 9 write)
write = sends, deletes, buys or postsRead from the package source without running it. The installed server may list more.
consume_messages\u5F9E\u6307\u5B9A topic \u62C9\u53D6\u8A0A\u606F(\u53EF\u6307\u5B9A consumer group \u8207\u6700\u5927\u7B46\u6578)\u3002\u26A0\uFE0F \u6703\u63D0\u4EA4 consumer group \u4F4D\u79FB(at-most-once):\u53D6\u56DE\u7684\u8A0A\u606F\u4E0D\u6703\u518D\u9001\u7B2C\u4E8C\u6B21,\u4E0D\u662F\u552F\u8B80\u67E5\u8A62\u3002
create_keywrite action\u5EFA\u7ACB\u65B0\u7684 API key(\u672C\u8EAB\u9700 admin scope,\u6B0A\u9650\u4E0D\u8DB3\u6642\u4E0D\u8981\u7528\u5B83\u81EA\u52A9\u958B\u901A)\u3002scope:admin|producer|consumer\u3002\u53EF\u9078 capabilities \u505A\u7D30\u7C92\u5EA6\u6388\u6B0A(scope \u9808 producer/consumer):[{ops:["publish"|"subscribe"],topics:["orders","support*","*"]}]
create_topicwrite action\u5EFA\u7ACB\u4E00\u500B\u4E8B\u4EF6 topic
create_webhookwrite action\u5EFA\u7ACB webhook:topic \u6709\u65B0\u8A0A\u606F\u6642 POST \u5230\u6307\u5B9A URL(\u53EF\u9078 secret \u505A HMAC \u7C3D\u7AE0)
delete_functionwrite action\u522A\u9664 topic \u7D81\u5B9A\u7684\u8A0A\u606F\u8F49\u63DB\u51FD\u6578
delete_keywrite action\u522A\u9664\u6307\u5B9A API key(\u4EE5 id)
delete_schemawrite action\u522A\u9664 topic \u7684\u6307\u5B9A schema \u7248\u672C(\u4E0D\u53EF\u522A\u6700\u65B0\u7248,\u5426\u5247\u56DE 409)
delete_topicwrite action\u522A\u9664\u6307\u5B9A topic\u3002**\u4E0D\u53EF\u9006**:\u8A72 topic \u7684\u6240\u6709\u8A0A\u606F\u3001\u6B7B\u4FE1\u4F47\u5217\u3001schema\u3001\u51FD\u6578\u8207 webhook \u7D81\u5B9A\u6703\u7ACB\u5373\u88AB\u6E05\u9664,\u540C\u540D\u91CD\u5EFA\u53EA\u6703\u5F97\u5230\u4E00\u500B\u5168\u65B0\u7684\u7A7A topic\u3002\u522A\u9664\u524D\u8ACB\u5148\u5411\u4F7F\u7528\u8005\u78BA\u8A8D\u3002
delete_webhookwrite action\u522A\u9664\u6307\u5B9A webhook(\u4EE5 id)
dlq_peek\u67E5\u770B topic \u7684\u6B7B\u4FE1\u4F47\u5217(DLQ)\u8A0A\u606F\u3002\u26A0\uFE0F \u5E95\u5C64\u8D70 committing poll:\u6703\u63D0\u4EA4 DLQ consumer group \u4F4D\u79FB,\u770B\u904E\u7684\u8A0A\u606F\u4E0D\u6703\u518D\u56DE\u4E00\u6B21,\u4E0D\u662F\u552F\u8B80\u67E5\u8A62(\u8981\u628A\u6B7B\u4FE1\u653E\u56DE\u4E3B topic \u8ACB\u7528 dlq_replay)
dlq_replay\u5C07 topic \u6B7B\u4FE1\u4F47\u5217(DLQ)\u8A0A\u606F\u91CD\u653E\u56DE\u539F topic(\u53EF\u9650\u5236\u7B46\u6578)\u3002\u6BCF\u5247\u91CD\u653E = \u4E00\u6B21 publish \u6CE8\u5165(\u8A72\u5247\u7684 units \u500B operations),\u5176\u5F8C\u7E8C\u6295\u905E\u7167\u5E38\u8A08;\u6CE8\u5165\u7AEF\u6D88\u8017\u65B9\u6848\u542B\u91CF,\u984D\u5EA6\u7528\u7F44\u6642\u8207 publish \u4E00\u6A23\u56DE 429,\
get_audit\u67E5\u8A62\u64CD\u4F5C\u5BE9\u8A08\u7D00\u9304(\u53EF\u6307\u5B9A\u7B46\u6578\u4E0A\u9650)
get_billing\u67E5\u8A62\u9810\u4ED8\u9918\u984D/\u8A08\u8CBB\u72C0\u614B/\u7E8C\u822A\u5929\u6578,\u4EE5\u53CA\u672C\u671F\u542B\u91CF\u7528\u91CF(included_msgs / period_operations,\u55AE\u4F4D\u70BA operations = \u6BCF 16 KiB \xD7(1 \u6B21\u767C\u5E03 + \u6BCF\u4E00\u6B21\u6295\u905E))
get_connection_snippet\u53D6\u5F97\u53EF\u8CBC\u7D66 AI \u7684\u63A5\u5165\u63D0\u793A
get_docs\u53D6\u5F97\u7531\u79DF\u6236 topics+schema \u751F\u6210\u7684 Markdown \u4F7F\u7528\u6587\u4EF6
get_function\u53D6\u5F97 topic \u7D81\u5B9A\u7684\u8A0A\u606F\u8F49\u63DB\u51FD\u6578
get_plan\u67E5\u8A62\u76EE\u524D\u65B9\u6848\u8207\u914D\u984D\u9650\u5236(\u4E5F\u662F\u6700\u8F15\u91CF\u7684\u6191\u8B49\u6AA2\u67E5:\u6210\u529F=key \u6709\u6548\u4E14\u5177 admin scope)
get_presence\u67E5\u8A62 topic \u76EE\u524D\u7DDA\u4E0A\u9023\u7DDA\u6578(realtime \u670D\u52D9)
get_schema\u53D6\u5F97 topic \u6700\u65B0\u7248\u672C\u7684 schema
get_usage\u67E5\u8A62\u79DF\u6236\u7528\u91CF(\u53EF\u6307\u5B9A\u65E5\u671F period=YYYY-MM-DD)\u3002\u8A08\u8CBB\u7DAD\u5EA6\u662F operations;messages / deliveries_* \u662F\u53EF\u898B\u6027\u7DAD\u5EA6,\u76F8\u52A0\u4E0D\u7B49\u65BC operations
list_keys\u5217\u51FA\u76EE\u524D\u6240\u6709 API key(\u50C5 prefix,\u4E0D\u542B\u5B8C\u6574 key)
list_schemas\u5217\u51FA topic \u6240\u6709 schema \u7248\u672C
list_topics\u5217\u51FA\u76EE\u524D\u6240\u6709 topic
list_webhooks\u5217\u51FA\u76EE\u524D\u6240\u6709 webhook
publish_messagewrite action\u767C\u9001\u4E00\u5247\u8A0A\u606F\u5230\u6307\u5B9A topic(\u53EF\u9078 room \u505A\u623F\u9593\u8DEF\u7531:\u540C\u623F\u8A0A\u606F\u4FDD\u8B49\u9806\u5E8F,\u8A02\u95B1\u7AEF\u7528\u540C\u4E00\u500B room \u6536)
register_function\u70BA topic \u8A3B\u518A\u8A0A\u606F\u8F49\u63DB\u51FD\u6578(\u8A0A\u606F\u9032\u5165\u6642\u57F7\u884C)\u3002language \u9810\u8A2D javascript(JS \u7A0B\u5F0F\u78BC);\u50B3 wasm \u5247 code \u9808\u70BA base64 \u7DE8\u78BC\u7684 WASI \u6A21\u7D44(\u8B80 stdin JSON\u3001\u5BEB stdout JSON)\u3002\u26A0\uFE0F \u540C\u4E00 topic \u53EA\u6709\u4E00\u500B\u51FD\u6578:\u91CD\u8907\u8A3B\u518A\u6703**\u8
register_schema\u70BA topic \u8A3B\u518A JSON Schema(compatibility:none/backward)\u3002\u6BCF\u6B21\u547C\u53EB\u90FD\u6703\u65B0\u589E\u4E00\u500B\u7248\u672C(\u975E\u51AA\u7B49)
set_planwatch_topic\u8A02\u95B1\u4E26\u300E\u7B49\u5F85\u300F\u67D0 topic \u7684\u4E0B\u4E00\u6279\u4E8B\u4EF6:\u9577\u8F2A\u8A62\u5230\u6709\u4E8B\u4EF6\u624D\u56DE(\u6216\u7B49\u5F85\u8996\u7A97\u903E\u6642\u56DE\u7A7A+\u63D0\u793A\u518D\u547C\u53EB)\u3002\u9069\u5408 AI agent \u76E3\u770B\u4E8B\u4EF6\u6D41\u2014\u2014\u6536\u5230\u5F8C\u8655\u7406\u3001\u518D\u6B21\u4EE5\u540C\u4E00 group \u547C\u53EB\u5373\u53EF
Public scan report
scanner v0.1.9 · 2026-09-20 · same rubric, same numbers if you re-run it
- Code scan2 source files scanned25/25
- –Live reliabilityno gateway calls yet and no remote to proben/a
- –Tool poisoningtools not inspected (local package is not executed); not countedn/a
- Auth qualitystatic API keys via environment variables6/15
- Maintenancelast push 12 days ago15/15
- Maintainer identitynamespace and repository owner differ; GitHub account older than a year; website matches verified namespace7/10
Install directly
Runs npx -y @msgmesh/mcp-server on your machine. Read the scan report first; the gateway never runs local packages.
claude mcp add msgmesh -- npx -y @msgmesh/mcp-server
MsgMesh: common questions
- Is MsgMesh MCP server safe?
- Mostly: it is graded B (82/100). Read the MsgMesh safety report
- How do I install MsgMesh?
- It runs on your machine. Copy the Claude Code, Claude Desktop or Cursor config from the install section.
- Does MsgMesh need an API key?
- Yes. The registry entry asks for
MQ_API_KEY. - Is MsgMesh maintained?
- The last commit was 13 days ago (2026-09-08). The latest release is v0.1.8.