Change Details

Using `messageID` to remove a certain message from the delivery queue, instead of using a receiver `deviceID` to remove all messages for the device. To achieve this the `DeliveryBroker` internal message structure needs to be changed from current `map[reciever deviceID] → vector<Message information>` to `map[receiver deviceID] → unordered_map[unique messageID] → Message information` . The `remove` function changed to `erase` and `remove` gets an additional `messageID` parameter to remove certain message items from the map. Usage of the functions is also refactored in AMQP and gRPC handlers. Related linear task: [[ https://linear.app/comm/issue/ENG-611/tunnelbroker-deliver-grpc-messages-to-the-stream-on-by-one | ENG-611 ]]

Using `messageID` to remove a certain message from the delivery queue, instead of using a receiver `deviceID` to remove all messages for the device. To achieve this the `DeliveryBroker` internal message structure needs to be changed from the current `map[reciever deviceID] → vector<Message information>` to `map[receiver deviceID] → Queue → Message information`. The `remove` function changed to `pop` to remove the first message from the queue. Usage of the functions is also refactored in AMQP and gRPC handlers. Related linear tasks: - [[ https://linear.app/comm/issue/ENG-611/tunnelbroker-deliver-grpc-messages-to-the-stream-on-by-one | ENG-611 ]] - [[ https://linear.app/comm/issue/ENG-609/stop-using-mutexes-in-deliverybroker | ENG-609 ]]

Using `messageID` to remove a certain message from the delivery queue, instead of using a receiver `deviceID` to remove all messages for the device. To achieve this the `DeliveryBroker` internal message structure needs to be changed from the current `map[reciever deviceID] → vector<Message information>` to `map[receiver deviceID] → unordered_map[unique messageID]Queue → Message information` . The `remove` function changed to `erase` and ``pop` to remove` gets an additional `messageID` parameter to remove certaine the first message itemse from the mapqueue. Usage of the functions is also refactored in AMQP and gRPC handlers. Related linear task: [[ https://linear.app/comm/issue/ENG-611/tunnelbroker-deliver-grpc-messages-to-the-stream-on-by-one | ENG-611s: - [[ https://linear.app/comm/issue/ENG-611/tunnelbroker-deliver-grpc-messages-to-the-stream-on-by-one | ENG-611 ]] - [[ https://linear.app/comm/issue/ENG-609/stop-using-mutexes-in-deliverybroker | ENG-609 ]]