Coreflux MQTT MCP Server
About
An enterprise-grade Model Context Protocol (MCP) server that provides secure, scalable access to Coreflux MQTT brokers and comprehensive automation capabilities for Claude and other MCP-compatible AI assistants.
Details
- Author
- CorefluxCommunity
- GitHub stars
- 3
- Downloads
- 206
- Categories
- Other
Jump to
- Seamless MQTT integration with full TLS support
- Full Coreflux API access (models, actions, rules, routes)
- LOT code generation via Coreflux Copilot API
- Dynamic discovery of available actions
- Comprehensive health monitoring and system checks
- Async processing with rate limiting and queue management
- Structured logging with rotation and security sanitization
Setting up with Highlight
This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:
- Download and install Highlight from highlightai.com/download
- Navigate to the plugins tab and select "Add Custom Plugin"
-
Configure the plugin with the settings below
Plugin Name
Coreflux MQTT MCP ServerCommand (node, npx, python, etc.)Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.
- Enable "Start Automatically" if you want the plugin to start when Highlight launches
From the repository
Deploy with Docker using docker-compose up -d, or install manually by cloning the repository, installing dependencies, configuring the .env file, and running python server.py. Connect it to Claude Desktop by adding a JSON configuration to the Claude config file or using environment variables.
Claude Desktop / Cursor
Paste into your MCP client config file to install this server.
{
"mcpServers": {
"coreflux mqtt mcp server": {
"Coreflux-MQTT-MCP-Server": {
"command": "python",
"args": [
"setup_assistant.py",
"#",
"Interactive",
"configuration"
]
}
}
}
}
McpServers
{
"Coreflux-MQTT-MCP-Server": {
"command": "python",
"args": [
"setup_assistant.py",
"#",
"Interactive",
"configuration"
]
}
}
Coreflux MQTT MCP Server
🚀 Features
Core Functionality
- 🔌 MQTT Integration: Seamless connection to Coreflux MQTT brokers with full TLS support - 🛠️ Complete Coreflux API: Full access to models, actions, rules, and routes - 🤖 AI Code Generation: LOT (Language-of-Things) code generation via Coreflux Copilot API - 🔍 Dynamic Discovery: Automatic discovery and listing of available actions - 🏥 Health Monitoring: Comprehensive system health checks and monitoringEnterprise Features
- 🔒 Production Security: Comprehensive log sanitization, input validation, and security features - ⚡ Async Processing: Non-blocking message processing with rate limiting and queue management - � Enhanced Logging: Structured logging with rotation, filtering, and security sanitization - ✅ Configuration Validation: Comprehensive environment and file validation system - 🧪 Testing Framework: Complete unit testing suite with mocking and coverage reportingDevOps & Deployment
- 🐳 Container Ready: Full Docker and Kubernetes deployment support with health checks - 🔄 CI/CD Pipeline: GitHub Actions with automated testing, security scanning, and quality checks - 📦 Development Tools: Pre-commit hooks, code formatting, linting, and documentation generation - ⚙️ Easy Setup: Interactive setup assistant with validation and testing - 📚 Rich Documentation: API documentation, security guides, and deployment instructionsQuick Start
Docker Deployment (Recommended)
1. Clone and configure: ``bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
cp .env.example .env
# Edit .env with your configuration
`
2. Deploy with Docker:
`bash
docker-compose up -d
`
🚀 Quick Start
Prerequisites
- Python 3.11 or higher
- Docker (optional, for containerized deployment)
- Access to a Coreflux MQTT broker
- Coreflux Copilot API key (optional, for AI assistance)
Option 1: Docker Deployment (Recommended)
1. Clone and configure:
`bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
cp .env.example .env
# Edit .env with your configuration
`
2. Deploy with Docker:
`bash
docker-compose up -d
`
3. Verify deployment:
`bash
docker-compose logs -f coreflux-mcp-server
`
Option 2: Development Installation
1. Clone and setup:
`bash
git clone https://github.com/CorefluxCommunity/Coreflux-MQTT-MCP-Server.git
cd Coreflux-MQTT-MCP-Server
`
2. Install dependencies:
`bash
pip install -r requirements.txt
# For development
pip install -r requirements-dev.txt
`
3. Configure environment:
`bash
python setup_assistant.py # Interactive configuration
# OR
cp .env.example .env && nano .env # Manual configuration
`
4. Validate and test:
`bash
make validate # Validate configuration
make test # Run tests
`
5. Start the server:
`bash
python server.py
# OR
make run
`
For detailed deployment instructions, see DEPLOYMENT.md.
⚙️ Configuration
Interactive Setup Assistant
The server includes a comprehensive setup assistant that guides you through configuration:
`bash
python setup_assistant.py
`
The assistant helps with:
- 🔧 MQTT broker connection settings
- 🔐 TLS certificate configuration
- 🤖 Coreflux Copilot API integration
- 📝 Logging and monitoring setup
- ✅ Configuration validation and testing
Use the setup assistant when:
- Creating initial configuration
- Updating existing settings
- Troubleshooting connection issues
- Setting up TLS certificates
- Migrating between environments
Environment Configuration
Copy .env.example to .env and configure:
``bashSign in to leave a review
Use Google, GitHub, or an email account so ratings stay tied to real people.
No reviews posted yet.



