Allows interaction with a Coreflux MQTT broker over MQTT, providing tools for broker command execution, live topic publish/subscribe, LoT lint and ordered deployment, project upload/export, route templates, action tracing, and documentation search.
Click on "Deploy Server".
Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state.
In the chat, type @ followed by the MCP server name and your instructions, e.g., "@Coreflux MQTT MCP Server Is the broker healthy?"
That's it! The server will respond to your query, and you can continue using it as needed.
Here is a step-by-step guide with screenshots.
Cursor Marketplace plugins for the Coreflux MQTT broker and LoT (Language of Things) — the DSL that defines actions, models, routes, rules, panels and themes on a Coreflux broker.
Plugin | What it gives the agent |
The full broker command surface over MQTT ( |
From the Cursor Marketplace, or add this repository as a plugin source. Then set the plugin variables (Cursor → Plugins → Coreflux):
Variable | Purpose |
|
|
| A user with |
| Optional fixed client id |
|
|
Alternatively drop a .broker file in the workspace root:
mqtt://192.168.1.10:1883
username=root
password=corefluxThe MCP server needs Node.js ≥ 20 on the machine running Cursor. It has no npm dependencies — the MQTT client is bundled.
Related MCP server: OMNI-MQTT-MCP
"Is the broker healthy?" → /coreflux-status
"Deploy this notebook and prove it works" → /coreflux-deploy
"Add a Modbus route for the PLC at 10.0.0.5, poll every second" → /coreflux-new-route
"Why does AlertOnOverheat never publish?" → /coreflux-debug-action
"Lock down devices/# so each gateway only publishes its own topics" → /coreflux-secure
"Scaffold a project for the packaging line" → /coreflux-new-project
Anything else: "list projects", "show me $SYS/Coreflux/Routes/+/status", "set secret
PG_PASSWORD", "publish {"v":1} to test/a", "what does -lotDiagnostic return"…
.cursor-plugin/marketplace.json marketplace manifest
plugins/coreflux/ the plugin (see its README); tests in plugins/coreflux/test
scripts/ validate, check, package and release tooling
.github/workflows/ CI (validate → unit matrix → broker e2e → package), release
docs/add-a-plugin.md how to add another plugin to this reponpm run validate # manifest + frontmatter checks
npm run check # version sync, hook/MCP wiring, docs ↔ tool names, line endings
npm test # unit + offline end-to-end tests (in-process fake broker)
npm run smoke # read-only checks against COREFLUX_MQTT_URL
npm run e2e # full round-trip against a real broker (creates and removes test entities)The MCP server is plugins/coreflux/scripts/mcp/coreflux-mqtt-mcp.mjs (stdio JSON-RPC). Run it
directly and paste JSON-RPC lines to experiment.
Every push and pull request runs the validators, the unit suite on Linux/macOS/Windows with
Node 20 and 22, and the end-to-end suite against coreflux/coreflux-mqtt-broker:latest. Tags
vX.Y.Z publish a GitHub release with the packaged plugin and its checksum.
Issues and PRs welcome — see CONTRIBUTING.md for the checks to run, how to write skills that stay true to the broker parser, and the release process. SECURITY.md covers vulnerability reports. Changes are tracked in CHANGELOG.md.
MIT — see LICENSE.
This server cannot be deployed
The bridge from K2 agents through Wrangler to your master AI - safe, approval-gated Cloudflare ops.
Hosted AgentLux MCP server for marketplace, identity, creator, services, and social flows.
Agent-native collaboration network: orchestrate a team of long-running agents from any MCP client.
Remote MCP server to read and manage your Atako AI agents, messages, files, and integrations.
