no send puback
vivainyan opened this issue · 0 comments
vivainyan commented
use CallbackConnection,When i receive a lot of publish package, it will no longer send ack package;
this is my code segment:
listener = new ExtendedListener() {
@OverRide
public void onPublish(UTF8Buffer topic, Buffer body, Callback<Callback> ack) {
ack.onSuccess(new Callback() {
@OverRide
public void onSuccess(Void value) {
logger.info("SEND PUBACK SUCCESSED!");
}
@Override
public void onFailure(Throwable value) {
logger.error("SEND PUBACK FAIL!");
}
});
}