MQTT Broker Node

M

Web/MQTT

MQTT Broker

Binds a lightweight MQTT broker for daemon workflows. Typed lifecycle events are exposed as pins; published messages are delivered to the referenced on-message handler.

mqtt_brokerwebLong running

Inputs2

Outputs7

Security exposure3/10

Packageweb

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.

3/10High

PrivacyPotential sensitivity of processed data.

2/10High

PerformanceRuntime or resource pressure.

4/10Medium

GovernancePolicy, audit, or compliance impact.

4/10Medium

ReliabilityOperational stability considerations.

4/10Medium

CostExternal or compute cost impact.

0/10High

Input Pins

2

Execute

Execution

exec_in

Start the MQTT broker

Config

Struct

config

MQTT broker configuration

SchemaMqttBrokerConfigMqttBrokerConfigMqttBrokerConfig5 fields

hoststringrequired

portinteger:uint16required

format uint16min 0max 65535

timeout_secondsinteger:uint64

format uint64default 0min 0

max_connectionsinteger:uint32

format uint32default 128min 0

tlsTlsConfig

default {"secure":false,"certificate":null,"ca_...

secureboolean

default false

certificateanyOf (2)

default null

variant 1TlsCertificatevariant

certificate_pemstringrequired

private_key_pemstringrequired

variant 2nullvariant

ca_certificate_pemstring | null

default null

server_namestring | null

default null

accept_invalid_certificatesboolean

default false

Schema enforced

Output Pins

7

On Listening

Execution

on_listening

Fires when the broker is bound and ready

Local Addr

String

local_addr

Bound broker socket address

On Client Connect

Execution

on_client_connect

Fires when an MQTT client connects

Client ID

String

client_id

Connected MQTT client id

Remote Addr

String

remote_addr

Remote client socket address

On Close

Execution

on_close

Fires when the broker stops

Error

Execution

exec_error

Fires if the broker fails to bind

Node Info

Internal name

mqtt_broker

Category

Web/MQTT

Function references

Can reference functions