Max 100 messages pubished

[tukusejssirs]

I use aedes as MQTT broker (one over MQTT protocol, the other over websockets) and Mqtt.js as client, however I always get 100 messages only, no matter if I publish by a client or the broker. After that, I am notified by the broker about heartbeats only.

I have no idea why this happens. I tried to create a minimal reproduction with 500 loops (using for), but it worked.

I start the MQTT servers like so:

const aedes = aedes.Server({queueLimit: 200})

const server = aedesServerFactory.createServer(aedes, {ws: true}) // ws
const server = net.createServer(aedes.handle) // mqtt

server.listen(port, () => console.log(`MQTT server started and listening on ${port}.`))

I also configure aedes.authorizePublish() to disable publishing by clients, however it does not matter.

Could anyone give me a clue why it does not work?

---

I am using aedes@0.46.2, mqtt@4.3.4, npm@8.1.1 and node@17.0.1.

[tukusejssirs]

Could this be caused because I publish a message every second (using cron) in every topic (currently, I have 60+ topics), therefore there are 60+ messages published every second.

Do I need to change some configuration to make it work like this?

[tukusejssirs]

I have just found out that I receive only so many message, as is the value of concurrency. Default is set to 100 (therefore I receive only 100 messages), when I raise it to 500, I receive 500 message only, then I receive no more messages.

I tried to subscribe to all on(${event}) on aedes side, but the only message I receive is from ping once a minute.

Could anyone explain this to me please?

As I understand it, concurrency property defines how many messages can be published concurrently, i.e. in any one moment, however, it does not work so. I have just raised its value to 20000 and when I publish 20,000 messages, it stops publishing more messages.

In the end, I have a requirement to be able to up to publish 7-10 messages per machine per second. Is it even possible?

[tukusejssirs]

I think this is sort of related to #666. For testing purposes, I subscribe to everything (using #).

[tukusejssirs]

When I set concurrency to 0, all seems to work as expected (by me, at least). That is good enough for me.