I have a Mqtt client. I need it to publish each element with 5 seconds interval and receive each in on_message callback. But my code publishes each element with same no of times as array length.

Example -

My code

var mqtt    = require('mqtt');
var client  = mqtt.connect("mqtt://broker.emqx.io:1883",{clientId:"mqtt_AYA"});

var arr = [1,2,3,4];
var options={
    retain:true,
    qos:1};
    
client.on("connect",function(){ 
    console.log("connected  "+ client.connected);
    })

arr.forEach(no => {
    client.on('message',function(topic, message, packet){
        console.log("message is "+ JSON.parse(message));
        // console.log("topic is "+ topic);
    });
    
    setInterval(function(){client.publish('/topic', JSON.stringify(no), options)},5000);

    client.subscribe('/topic', {qos:1});

});

Result -

connected  true
message is 1
message is 1
message is 1
message is 1
message is 2
message is 2
message is 2
message is 2
message is 3
message is 3
message is 3
message is 3
message is 4
message is 4
message is 4
message is 4
[5 secs interval]
Repetition of above 

But I need -

connected  true
message is 1
[5 secs interval]
message is 2
[5 secs interval]
message is 3
[5 secs interval]
message is 4
[5 secs interval]
and end the client