Ensumer Mocked BK client triggers the addEntry callbacks in order
@@ -181,7 +181,7 @@ public class PulsarMockLedgerHandle extends LedgerHandle {
} else {
cb.addComplete(BKException.Code.OK, PulsarMockLedgerHandle.this, entryId, ctx);
}
- });
+ }, bk.executor);
}
@Override
