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