Skip to content

[bug] Not all messages are consumed when dedupe is enabled #955

@zagadheesh

Description

@zagadheesh

System Information

  • Aedes: 0.51.1
  • NodeJS: 16.15.0
  • OS: Mac OS 14.5
  • Arch: x86_64
  • Java: 1.8

Describe the bug
I'm currently experiencing an issue while running Aedes alongside an MQTT Java client using example.js (attached) with no modifications to the aedes source code. Despite running both the consumer and producer, it seems that certain messages aren't being consumed. Interestingly, after commenting out the 'dedupe' call in the client.js file of the Aedes source code, the consumer is able to successfully consume all messages.

To Reproduce
Steps to reproduce the behavior:

  1. Run the broker using example.js on aedes 0.51.1 source code
  2. Run AedesSampleConsumer.java
  3. Run AedesSampleProducer.java

Expected behavior
Consumer should consume all the messages produced.

aedes-problem-demo.zip

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions