This is an automated email from the ASF dual-hosted git repository.
bogong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from e29f720 [Transaction] Transaction coordinator client connect add
response command. (#12301)
add 8b50af5 [Transaction] Transaction pending ack lazy init. (#11091)
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/ManagedLedgerFactory.java | 1 -
.../service/persistent/PersistentSubscription.java | 8 +-
.../transaction/pendingack/PendingAckHandle.java | 18 +-
.../TransactionPendingAckStoreProvider.java | 9 +
.../impl/InMemoryPendingAckStoreProvider.java | 5 +
.../pendingack/impl/MLPendingAckReplyCallBack.java | 19 +-
.../pendingack/impl/MLPendingAckStoreProvider.java | 9 +
.../pendingack/impl/PendingAckHandleDisabled.java | 12 +-
.../pendingack/impl/PendingAckHandleImpl.java | 245 +++++++++++++++++++--
.../pendingack/impl/PendingAckHandleState.java | 17 +-
.../broker/admin/v3/AdminApiTransactionTest.java | 30 ++-
.../persistent/PersistentSubscriptionTest.java | 5 +
.../broker/stats/TransactionMetricsTest.java | 28 ++-
.../TopicTransactionBufferRecoverTest.java | 2 +-
.../buffer/TransactionBufferClientTest.java | 8 -
15 files changed, 343 insertions(+), 73 deletions(-)
