Give Feedback

Coreflux MQTT Broker

Generated on 24 Oct 2025 from the Coreflux MQTT Broker catalog page

Application Description

Coreflux MQTT Broker is a programmable automation platform built for Industrial IoT, smart manufacturing, and edge AI.

It enables real-time data routing, transformation, and automation through the Language of Things (LOT) — a human-readable logic system that runs directly inside the broker.

This 1-Click App deploys a fully functional Coreflux MQTT Broker with WebSocket, TLS, and LOT support.

Connect PLCs, sensors, and cloud systems securely, and start building industrial automation flows in minutes.

📘 Documentation: https://docs.coreflux.org

🐳 Docker Hub:https://hub.docker.com/r/coreflux/coreflux-mqtt-broker

🌐 Website:https://coreflux.org

💬 Discord:https://discord.gg/P9qjWQUt

Software Included

This Marketplace listing does not include a detailed software list.

Creating an App using the Control Panel

Click the Deploy to DigitalOcean button to create a Droplet based on this 1-Click App. If you aren’t logged in, this link will prompt you to log in with your DigitalOcean account.

Creating an App using the API

In addition to creating a Droplet from the Coreflux MQTT Broker 1-Click App using the control panel, you can also use the DigitalOcean API. As an example, to create a 4GB Coreflux MQTT Broker Droplet in the SFO2 region, you can use the following curl command. You need to either save your API access token to an environment variable or substitute it in the command below.

curl -X POST -H 'Content-Type: application/json' \
         -H 'Authorization: Bearer '$TOKEN'' -d \
        '{"name":"choose_a_name","region":"sfo2","size":"s-2vcpu-4gb","image":"coreflux-corefluxmqttbrok"}' \
        "https://api.digitalocean.com/v2/droplets"

Getting Started After Deploying Coreflux MQTT Broker

Getting Started

🔐 Connect to Your Droplet

After the Droplet is created, connect via SSH:

ssh root@your_droplet_public_ipv4

Replace your_droplet_public_ipv4 with the public IP address shown in your DigitalOcean dashboard.

On login, you’ll see the Coreflux welcome banner containing broker information and TLS setup instructions.

🚀 Accessing the Coreflux MQTT Broker

Your Coreflux MQTT Broker is already running and listening on these ports:

Protocol	Port	Description
MQTT (plain)	1883	Standard unencrypted MQTT
MQTT over TLS	1884	Secure MQTT (TLS)
WebSocket	5000	WebSocket connection (ws://)
WebSocket Secure	443	Secure WebSocket (wss://, TLS)

To enable encryption, place your TLS certificate and key files in:

/opt/coreflux/tls/server.crt
/opt/coreflux/tls/server.key

Restart the broker after adding certificates:

sudo systemctl restart coreflux-broker

🧪 Test the Broker Using Mosquitto

Install the Mosquitto client locally:

sudo apt install -y mosquitto-clients

Publish a test message:

mosquitto_pub -h your_droplet_public_ipv4 -p 1883 -t "coreflux/test" -m "Hello from Coreflux"

Subscribe to the same topic:

mosquitto_sub -h your_droplet_public_ipv4 -p 1883 -t "coreflux/test"

Expected output:

Hello from Coreflux

📘 Learn More

Your Coreflux broker is now ready to connect devices, sensors, and cloud systems using the Language of Things (LOT) for automation, routing, and real-time data transformation.