I want to use HiveMQ extension to send messages from server directly to clients (messages will come from Kafka queue) and then get a callback when they are successfully delivered (PUBACK).
PublishService.publishToClient returns future with DELIVERED or FAILED status, but I think the DELIVERED status only refers to a message being enqueued for sending.
I noticed there is a new branch in hivemq ce repository (feature/puback-inbound-interceptor) that adds an interceptor for incoming PUBACK messages.
How can I correlate sent message with received acknowledgement? I don’t get packed Id from PublishService.publish so I can’t match it to PubackPacket.getPacketIdentifier .
If I set user properties in PublishService.publish, will I get the same properties back in puback?