fusesource/mqtt-client

no send puback

vivainyan opened this issue · 0 comments

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!");
                }
            });

}