CorefluxMCPServer
Connects Claude and other MCP-compatible AI assistants to a Coreflux MQTT broker, enabling them to discover and execute Coreflux commands for managing models, actions, rules, and routes through natural language.
Connects Claude and other MCP-compatible AI assistants to a Coreflux MQTT broker, enabling them to discover and execute Coreflux commands for managing models, actions, rules, and routes through natural language.
This is a Model Context Protocol (MCP) server that connects to a Coreflux MQTT broker and makes Coreflux and MQTT actions available as tools for Claude and other MCP-compatible AI assistants.
The server includes a standalone setup assistant that can be run separately from the main server. Run the setup assistant when:
To run the setup assistant:
python setup_assistant.py
The setup assistant helps you:
.env file with your configurationAfter configuration is complete, you can run the server normally.
~/Library/Application Support/Claude/claude_desktop_config.json (macOS/Linux) or %USERPROFILE%AppDataRoamingClaudeclaude_desktop_config.json (Windows){
"mcpServers": {
"coreflux": {
"command": "python",
"args": [
"/PATH/TO/server.py",
"--mqtt-host", "localhost",
"--mqtt-port", "1883",
"--mqtt-user", "root",
"--mqtt-password", "coreflux",
"--mqtt-client-id", "claude-coreflux-client"
],
"description": "Coreflux MQTT Broker Control",
"icon": "?",
"env": {}
}
}
}The server accepts the following command-line arguments. These settings can also be configured via the .env file using the setup assistant:
| Argument | Description | Default |
|---|---|---|
--mqtt-host |
MQTT broker address | localhost |
--mqtt-port |
MQTT broker port | 1883 |
--mqtt-user |
MQTT username | - |
--mqtt-password |
MQTT password | - |
--mqtt-client-id |
MQTT client ID | claude-mcp-client |
--mqtt-use-tls |
Enable TLS for MQTT connection | false |
--mqtt-ca-cert |
Path to CA certificate file | - |
--mqtt-client-cert |
Path to client certificate file | - |
--mqtt-client-key |
Path to client key file | - |
--log-level |
Logging level (DEBUG/INFO/WARNING/ERROR/CRITICAL) | INFO |
The server provides tools for common Coreflux commands:
add_rule: Add a new permission ruleremove_rule: Remove a permission ruleadd_route: Add a new route connectionremove_route: Remove a route connectionadd_model: Add a new model structureremove_model: Remove a model structureadd_action: Add a new action event/functionremove_action: Remove an action event/functionrun_action: Run an action event/functionremove_all_models: Remove all modelsremove_all_actions: Remove all actionsremove_all_routes: Remove all routeslist_discovered_actions: List all discovered Coreflux actionsrequest_lot_code: Generate LOT code based on natural language promptsIf you encounter issues:
python setup_assistant.py# Check Claude's logs for errors (macOS/Linux)
tail -n 20 -f ~/Library/Logs/Claude/mcp*.log
# Windows PowerShell
Get-Content -Path "$env:USERPROFILEAppDataRoamingClaudeLogsmcp*.log" -Tail 20 -Wait# Direct execution with debug logging
python server.py --mqtt-host localhost --mqtt-port 1883 --log-level DEBUG