# MQTT Message Not Being Sent

**URL:** <https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504>\
**Category:** General\
**Tags:** mqtt\
**Created:** [28 August 2024 12:41 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504 "2024-08-28T12:41:17Z")\
**Posts on this page:** 20\
**Page:** 1

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [28 August 2024 12:41 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/1 "2024-08-28T12:41:17Z")

</div>

Hi Team,

I have a dashboard that I use for scheduling, I use inject nodes injecting into function blocks.  
The function blocks contain several message.

Example

```auto
let var_obj_message = {};

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/scheduler";
var_obj_message.payload = "05:00:00";
node.send(var_obj_message);

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/switch/01";
var_obj_message.payload = "off";
node.send(var_obj_message);

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/switch/02";
var_obj_message.payload = "off";
node.send(var_obj_message);

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/switch/03";
var_obj_message.payload = "off";
node.send(var_obj_message);

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/switch/04";
var_obj_message.payload = "off";
node.send(var_obj_message);

var_obj_message.topic = "feeds/thing-x/process-io-z/incoming/io/switch/05";
var_obj_message.payload = "off";
node.send(var_obj_message);

```

For some odd reason only the first message gets sent, I added a debug node and looking at that it shows all the messages being sent.

I run two of the same type of things and these work fine without any issues.

This is my debug output

```auto
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '10:00:00',
  _msgid: '49abbcd39f74fc36'
}
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'off',
  _msgid: '49abbcd39f74fc36'
}
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/02',
  payload: 'off',
  _msgid: '49abbcd39f74fc36'
}
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/03',
  payload: 'off',
  _msgid: '49abbcd39f74fc36'
}
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/04',
  payload: 'off',
  _msgid: '49abbcd39f74fc36'
}
28 Aug 10:00:00 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/05',

```

---

<div class="post-metadata">

**Author:** ![jbudd](https://avatars.discourse-cdn.com/v4/letter/j/5f8ce5/32.png) [@jbudd](https://discourse.nodered.org/u/jbudd)\
**Post date:** [28 August 2024 12:53 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/2 "2024-08-28T12:53:08Z")

</div>

> [@wcx](#):
>
> For some odd reason only the first message gets sent

How do you know that?

If you create a debug and an mqtt-in node subscribed to `feeds/thing-x/process-io-z/incoming/io/switch/#` what does it show?

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [28 August 2024 13:10 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/3 "2024-08-28T13:10:58Z")

</div>

let me add that and check, I used mosquitto\_sub to check

---

<div class="post-metadata">

**Author:** ![Colin](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/colin/32/17040_2.png) [@Colin](https://discourse.nodered.org/u/Colin)\
**Post date:** [28 August 2024 15:14 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/4 "2024-08-28T15:14:04Z")

</div>

Install MQTTExplorer on a PC, it is an excellent way of seeing what is going on with MQTT.

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 03:33 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/5 "2024-08-29T03:33:17Z")

</div>

This is the debug output for the mqtt receiver subscripted to that topic, only the first two messages are sent

```auto
28 Aug 22:50:01 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '22:50:00',
  qos: 2,
  retain: false,
  _msgid: 'cdeb3f5e34d41c06'
}
28 Aug 22:50:01 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: 'f09749e4dfee535d'
}
29 Aug 00:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '00:00:00',
  qos: 2,
  retain: false,
  _msgid: '183d77f646604476'
}
29 Aug 00:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: '6711ee391f7131fd'
}
29 Aug 01:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '01:00:00',
  qos: 2,
  retain: false,
  _msgid: '8b37d66a719b1619'
}
29 Aug 01:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: 'a9877310f0cf94b7'
}
29 Aug 02:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '02:00:00',
  qos: 2,
  retain: false,
  _msgid: '17e64a6a5d8402dc'
}
29 Aug 02:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: '7bfde283e829467e'
}
29 Aug 05:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '05:00:00',
  qos: 2,
  retain: false,
  _msgid: 'b979eec32545c781'
}
29 Aug 05:00:00 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'off',
  qos: 2,
  retain: false,
  _msgid: '6bc4c3154baaab51'
}

```

---

<div class="post-metadata">

**Author:** ![jbudd](https://avatars.discourse-cdn.com/v4/letter/j/5f8ce5/32.png) [@jbudd](https://discourse.nodered.org/u/jbudd)\
**Post date:** [29 August 2024 05:44 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/6 "2024-08-29T05:44:20Z")

</div>

![image](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/a/a/aaabc53b3eb63c07b2a8228fcd49a1296efe7c8a.png)  
On my computer with this flow, the function sends 6 messages eg  
 ![image](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/0/9/09e9044d53c468783aaedf51d7d89d96c1d7413f.png)

If I feed them through mqtt-out and mqtt-in (Mosquitto) I see all 6 messages eg  
 ![image](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/6/f/6f8e73ada5d4ab34b39228e2a393c9d3eeabc506.png)

What version of Node-red do you have?  
What platform are you running it on?  
What MQTT broker are you using?  
Can you show us a screen capture of your flow?

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 05:58 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/7 "2024-08-29T05:58:24Z")

</div>

![image](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/6/d/6d4681ba2aa2b037e1b5ea408704d2d68054e765.png)

What version of Node-red do you have?  
V4.0.0

What platform are you running it on?  
Raspberry Pi 5

What MQTT broker are you using?  
Mosquito

The odd thing is I have several of these that all work fine except for this one.

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 06:01 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/8 "2024-08-29T06:01:07Z")

</div>

Here is a export

```auto
[
    {
        "id": "72c7a56419da2980",
        "type": "tab",
        "label": "wcx.io.z.scheduling",
        "disabled": false,
        "info": "",
        "env": []
    },
    {
        "id": "3b7a6f0b1e6d6c1d",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"05:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 40,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "3d9ce95c723d8517",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"05:50:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 100,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "a1c614234917a123",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"10:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 160,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "f5ea6dde6102dd4a",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"15:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 220,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "b10514be95ac0885",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"15:50:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 280,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "f27cbcb83a6bd4f9",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"17:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 340,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "54231b96a8a542c0",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"17:50:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 400,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "c5a9e93d6988f581",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"22:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 460,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "c27983ee91f8d4a9",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"22:50:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 520,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "dbbc5bb517919a95",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"00:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 580,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "92e48d9deebc7b49",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"01:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 640,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "044f4fa004ce3053",
        "type": "function",
        "z": "72c7a56419da2980",
        "name": "function.io.switch",
        "func": "let var_obj_message = {};\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/scheduler\";\nvar_obj_message.payload = \"02:00:00\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/01\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/02\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/03\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/04\";\nvar_obj_message.payload = \"on\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/05\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/06\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/07\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nvar_obj_message.topic = \"feeds/thing-x/process-io-z/incoming/io/switch/08\";\nvar_obj_message.payload = \"off\";\nnode.send(var_obj_message);\n\nnode.done();",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 700,
        "wires": [
            [
                "a0ceeabe7e0f461a",
                "fecd7f06c22b8be4"
            ]
        ]
    },
    {
        "id": "a0ceeabe7e0f461a",
        "type": "mqtt out",
        "z": "72c7a56419da2980",
        "name": "mqtt.out",
        "topic": "",
        "qos": "2",
        "retain": "",
        "respTopic": "",
        "contentType": "",
        "userProps": "",
        "correl": "",
        "expiry": "",
        "broker": "66d480061cc03526",
        "x": 980,
        "y": 320,
        "wires": []
    },
    {
        "id": "277f52a91b7b5c17",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.05:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 05 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 40,
        "wires": [
            [
                "3b7a6f0b1e6d6c1d"
            ]
        ]
    },
    {
        "id": "4733b44d1ebb6cc1",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.05:50:00",
        "props": [],
        "repeat": "",
        "crontab": "50 05 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 100,
        "wires": [
            [
                "3d9ce95c723d8517"
            ]
        ]
    },
    {
        "id": "78376189bdd6ddde",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.10:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 10 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 160,
        "wires": [
            [
                "a1c614234917a123"
            ]
        ]
    },
    {
        "id": "a4392b6bc648acfe",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.15:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 15 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 220,
        "wires": [
            [
                "f5ea6dde6102dd4a"
            ]
        ]
    },
    {
        "id": "11258e95c1b5121e",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.15:50:00",
        "props": [],
        "repeat": "",
        "crontab": "50 15 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 280,
        "wires": [
            [
                "b10514be95ac0885"
            ]
        ]
    },
    {
        "id": "6c98db62247b7458",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.17:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 17 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 340,
        "wires": [
            [
                "f27cbcb83a6bd4f9"
            ]
        ]
    },
    {
        "id": "da080917fb1e8b49",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.17:50:00",
        "props": [],
        "repeat": "",
        "crontab": "50 17 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 400,
        "wires": [
            [
                "54231b96a8a542c0"
            ]
        ]
    },
    {
        "id": "de26f9dd825e8cce",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.22:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 22 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 460,
        "wires": [
            [
                "c5a9e93d6988f581"
            ]
        ]
    },
    {
        "id": "447c1a309630afd9",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.22:50:00",
        "props": [],
        "repeat": "",
        "crontab": "50 22 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 520,
        "wires": [
            [
                "c27983ee91f8d4a9"
            ]
        ]
    },
    {
        "id": "c0d37f3cc00f8231",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.00:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 00 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 580,
        "wires": [
            [
                "dbbc5bb517919a95"
            ]
        ]
    },
    {
        "id": "5458ec52644050a0",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.01:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 01 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 640,
        "wires": [
            [
                "92e48d9deebc7b49"
            ]
        ]
    },
    {
        "id": "6064ef3f7eecc564",
        "type": "inject",
        "z": "72c7a56419da2980",
        "name": "inject.02:00:00",
        "props": [],
        "repeat": "",
        "crontab": "00 02 * * *",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 120,
        "y": 700,
        "wires": [
            [
                "044f4fa004ce3053"
            ]
        ]
    },
    {
        "id": "fecd7f06c22b8be4",
        "type": "debug",
        "z": "72c7a56419da2980",
        "name": "debug.out.mqtt",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": true,
        "complete": "true",
        "targetType": "full",
        "statusVal": "",
        "statusType": "counter",
        "x": 1000,
        "y": 380,
        "wires": []
    },
    {
        "id": "756704d8d7c552fc",
        "type": "mqtt in",
        "z": "72c7a56419da2980",
        "name": "mqtt.in",
        "topic": "feeds/thing-x/process-io-z/incoming/io/#",
        "qos": "2",
        "datatype": "auto-detect",
        "broker": "66d480061cc03526",
        "nl": false,
        "rap": true,
        "rh": 0,
        "inputs": 0,
        "x": 970,
        "y": 180,
        "wires": [
            [
                "215aab6898d7d89d"
            ]
        ]
    },
    {
        "id": "215aab6898d7d89d",
        "type": "debug",
        "z": "72c7a56419da2980",
        "name": "debug.in.mqtt",
        "active": true,
        "tosidebar": true,
        "console": true,
        "tostatus": true,
        "complete": "true",
        "targetType": "full",
        "statusVal": "",
        "statusType": "counter",
        "x": 1200,
        "y": 180,
        "wires": []
    },
    {
        "id": "66d480061cc03526",
        "type": "mqtt-broker",
        "name": "wcx-services-mqtt",
        "broker": "",
        "port": "5050",
        "clientid": "node-red-z",
        "autoConnect": true,
        "usetls": false,
        "protocolVersion": "4",
        "keepalive": "50",
        "cleansession": true,
        "autoUnsubscribe": true,
        "birthTopic": "",
        "birthQos": "0",
        "birthRetain": "false",
        "birthPayload": "",
        "birthMsg": {},
        "closeTopic": "",
        "closeQos": "0",
        "closeRetain": "false",
        "closePayload": "",
        "closeMsg": {},
        "willTopic": "",
        "willQos": "0",
        "willRetain": "false",
        "willPayload": "",
        "willMsg": {},
        "userProps": "",
        "sessionExpiry": ""
    }
]

```

---

<div class="post-metadata">

**Author:** ![Trying\_to\_learn](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/trying_to_learn/32/28400_2.png) [@Trying\_to\_learn](https://discourse.nodered.org/u/Trying_to_learn)\
**Post date:** [29 August 2024 06:01 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/9 "2024-08-29T06:01:10Z")

</div>

I think you may have to give a _bit more_ information about which mosquitto version you have.

Which one, version, etc.

---

<div class="post-metadata">

**Author:** ![jbudd](https://avatars.discourse-cdn.com/v4/letter/j/5f8ce5/32.png) [@jbudd](https://discourse.nodered.org/u/jbudd)\
**Post date:** [29 August 2024 06:46 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/10 "2024-08-29T06:46:49Z")

</div>

Is mosquitto on the same computer as Node-red?

You could try putting a delay node in front of mqtt-out to rate limit it to eg 10 messages per second but I doubt if it will make a difference.

I find Mosquitto on a Pi very reliable and capable but you could experiment with a cloud based broker such as hivemq.

---

<div class="post-metadata">

**Author:** ![Colin](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/colin/32/17040_2.png) [@Colin](https://discourse.nodered.org/u/Colin)\
**Post date:** [29 August 2024 07:40 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/11 "2024-08-29T07:40:53Z")

</div>

> [@wcx](#):
>
> What version of Node-red do you have?  
> V4.0.0

Please upgrade to the latest, though I do not expect it to make a difference.

> [@jbudd](#):
>
> You could try putting a delay node in front of mqtt-out to rate limit it to eg 10 messages per second but I doubt if it will make a difference.

Node red and mosquitto will easily handle thousands of messages a second, it isn't that.

Please change the debug nodes also Output to Console, then stop and start node-red in a command window, then run your code to publish the messages. Then copy/paste the complete command window output here please. Copy/paste not screenshot please.

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 08:59 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/12 "2024-08-29T08:59:04Z")

</div>

```auto
29 Aug 10:57:35 - [info]
Welcome to Node-RED
===================
29 Aug 10:57:35 - [info] Node-RED version: v4.0.2
29 Aug 10:57:35 - [info] Node.js version: v18.20.3
29 Aug 10:57:35 - [info] Linux 6.6.20+rpt-rpi-2712 arm64 LE
29 Aug 10:57:35 - [info] Loading palette nodes
29 Aug 10:57:35 - [info] Dashboard version 3.6.5 started at /
29 Aug 10:57:36 - [info] Settings file : /home/admin/.node-red/settings.js
29 Aug 10:57:36 - [info] Context store : 'default' [module=memory]
29 Aug 10:57:36 - [info] User directory : /home/admin/.node-red
29 Aug 10:57:36 - [warn] Projects disabled : editorTheme.projects.enabled=false
29 Aug 10:57:36 - [info] Flows file : /home/admin/.node-red/flows.json
29 Aug 10:57:36 - [info] Server now running at http://127.0.0.1:8080/admin/
29 Aug 10:57:36 - [info] Starting flows
29 Aug 10:57:36 - [info] Started flows
29 Aug 10:57:36 - [info] [xxxxx] Connected to broker: node-red-z@mqtt://wxxx
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '05:50:00',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/02',
  payload: 'on',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/03',
  payload: 'on',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/04',
  payload: 'on',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/05',
  payload: 'off',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/06',
  payload: 'off',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/07',
  payload: 'off',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.out.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/08',
  payload: 'off',
  _msgid: 'b291cdc418d47b5b'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/scheduler',
  payload: '05:50:00',
  qos: 2,
  retain: false,
  _msgid: 'c9858afb865a5569'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/01',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: 'cb8bca6cf611d391'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/02',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: 'ffb985a26b684b86'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/03',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: 'a2240bdd2feae961'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/04',
  payload: 'on',
  qos: 2,
  retain: false,
  _msgid: '3ae9b998028543f4'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/05',
  payload: 'off',
  qos: 2,
  retain: false,
  _msgid: '2c3701de2b191280'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/06',
  payload: 'off',
  qos: 2,
  retain: false,
  _msgid: 'fab0d0714500cb6b'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/07',
  payload: 'off',
  qos: 2,
  retain: false,
  _msgid: '2ffe56462377073c'
}
29 Aug 10:57:56 - [info] [debug:debug.in.mqtt]
{
  topic: 'feeds/thing-x/process-io-z/incoming/io/switch/08',
  payload: 'off',
  qos: 2,
  retain: false,
  _msgid: '04edc635e6358dd1'
}

```

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 09:02 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/13 "2024-08-29T09:02:56Z")

</div>

Broker is on a separate PI 5, stage thing is if I run trigger the inject manually it works fine

---

<div class="post-metadata">

**Author:** ![Trying\_to\_learn](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/trying_to_learn/32/28400_2.png) [@Trying\_to\_learn](https://discourse.nodered.org/u/Trying_to_learn)\
**Post date:** [29 August 2024 09:06 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/14 "2024-08-29T09:06:56Z")

</div>

> [@wcx](#):
>
> stage thing is if I run trigger the inject manually it works fine

Sorry, I am trying to not get too involved. But also would like to help.

Which `inject` node?

On the screen shot you posted, there are quite a few of them.

Or is it if you press **ANY** `inject` node it works?  
(Just for clarity)

Oh, another question that I feel needs to be asked:  
Is that PI 5 on the same subnet/vlan as the other machines?  
Sorry, just I have been caught with VLAN/subnet traps and it was a bit annoying.

Oh, also - sorry:  
Could you draw a _basic_ map of your network?

eg:

 ![basic network map](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/f/a/fa7a953d7db0e6458c1fad22f825be0db02c1766.png)

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 09:36 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/15 "2024-08-29T09:36:54Z")

</div>

Any of the inject nodes. If I tigger them manualy messages comes through no issues, If they are triggered by the time interval only the first two messages are sent.

All on the same subnet no plans.

---

<div class="post-metadata">

**Author:** ![wcx](https://avatars.discourse-cdn.com/v4/letter/w/3d9bf3/32.png) [@wcx](https://discourse.nodered.org/u/wcx)\
**Post date:** [29 August 2024 09:38 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/16 "2024-08-29T09:38:35Z")

</div>

and on the same node red server I have identical flows but different topics that all work fine no issues

---

<div class="post-metadata">

**Author:** ![Trying\_to\_learn](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/trying_to_learn/32/28400_2.png) [@Trying\_to\_learn](https://discourse.nodered.org/u/Trying_to_learn)\
**Post date:** [29 August 2024 09:41 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/17 "2024-08-29T09:41:18Z")

</div>

Ok, sorry. To me the question was begging to be asked.

_Indulge me_  
Could you open one/any of those `function` nodes and copy/paste the code?

I am at a loss to see.....

> [@wcx](#):
>
> If they are triggered by the time interval only the first two messages are sent.

I'm not seeing where the _time interval_ is injected.

Ok, at this point you may be torn between posting ALL the flow - not really good for people sometimes/most time - but I would like to see how it is supposed to work.

> [@wcx](#):
>
> and on the same node red server I have identical flows but different topics that all work fine no issues

Ok, from that:

What are the `MQTT OUT` nodes set to?

Just in case their `topics` are set differently.

Maybe take screen shots of them both.

The working one and the non working one.

Shrug.  
Just sharing ideas.

# HANG ON!!??

> I have identical flows but different topics that all work fine

Sorry, _that does not compute_ (lost in space 70's show reference)

---

<div class="post-metadata">

**Author:** ![zenofmud](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/zenofmud/32/316_2.png) [@zenofmud](https://discourse.nodered.org/u/zenofmud)\
**Post date:** [29 August 2024 10:35 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/18 "2024-08-29T10:35:52Z")

</div>

Try adding a `delay` node after the `function` node and set it to 5 milliseconds and see if that changes anything. The reason I'm suggesting that is because in your debug the `_msgid` is the same in each of the debug:debug.out.mqtt you show.

---

<div class="post-metadata">

**Author:** ![Colin](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/colin/32/17040_2.png) [@Colin](https://discourse.nodered.org/u/Colin)\
**Post date:** [29 August 2024 12:20 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/19 "2024-08-29T12:20:46Z")

</div>

> [@wcx](#):
>
> If I tigger them manualy messages comes through no issues, If they are triggered by the time interval only the first two messages are sent.

Leave the log open and wait for a triggered inject and see what you see in the log then.

---

<div class="post-metadata">

**Author:** ![Colin](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/colin/32/17040_2.png) [@Colin](https://discourse.nodered.org/u/Colin)\
**Post date:** [29 August 2024 12:23 UTC](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504/20 "2024-08-29T12:23:16Z")

</div>

> [@zenofmud](#):
>
> The reason I'm suggesting that is because in your debug the `_msgid` is the same in each of the debug:debug.out.mqtt you show.

That will likely be because they are all clones of the same original message. `node.send()` clones the message when it sends it, but that will not change the msg id.  
I suspect something else is happening at the same time when the node triggers on the interval and is crashing node-red or locking something up. or something similar.

[Next page](https://discourse.nodered.org/t/mqtt-message-not-being-sent/90504.md?page=2)