This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 086906d Fix collection get bug in ResourceGroupService (#12499)
add 15a2303 [Transaction] Merge transactionBuffer exception into a class
(#12358)
No new revisions were added by this update.
Summary of changes:
.../broker/TransactionMetadataStoreService.java | 6 +-
.../PersistentDispatcherMultipleConsumers.java | 4 +-
.../PersistentDispatcherSingleActiveConsumer.java | 4 +-
.../streamingdispatch/StreamingEntryReader.java | 4 +-
.../buffer/TransactionBufferReader.java | 5 +-
.../broker/transaction/buffer/TransactionMeta.java | 6 +-
.../exceptions/EndOfTransactionException.java | 31 --------
.../NoTxnsCommittedAtLedgerException.java | 31 --------
.../TransactionBufferProviderException.java | 30 -------
.../exceptions/TransactionNotFoundException.java | 31 --------
.../exceptions/TransactionNotSealedException.java | 31 --------
.../exceptions/TransactionSealedException.java | 33 --------
.../exceptions/TransactionStatusException.java | 37 ---------
.../exceptions/UnsupportedTxnActionException.java | 34 --------
.../buffer/impl/InMemTransactionBuffer.java | 48 ++++++------
.../buffer/impl/InMemTransactionBufferReader.java | 4 +-
.../exception/TransactionException.java | 83 ++++++++++++++++++++
.../buffer/TransactionBufferException.java | 91 ++++++++++++++++++++++
.../buffer}/package-info.java | 2 +-
.../TransactionCoordinatorException.java} | 29 +++++--
.../coordinator}/package-info.java | 2 +-
.../exceptions => exception}/package-info.java | 2 +-
.../TransactionPendingAckException.java} | 25 ++++--
.../pendingack}/package-info.java | 2 +-
...ransactionPendingAckStoreProviderException.java | 32 --------
.../pendingack/impl/MLPendingAckStoreProvider.java | 5 +-
.../buffer/InMemTransactionBufferReaderTest.java | 4 +-
.../transaction/buffer/TransactionBufferTest.java | 16 ++--
28 files changed, 275 insertions(+), 357 deletions(-)
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/EndOfTransactionException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/NoTxnsCommittedAtLedgerException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionBufferProviderException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionNotFoundException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionNotSealedException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionSealedException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/TransactionStatusException.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/UnsupportedTxnActionException.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/exception/TransactionException.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/exception/buffer/TransactionBufferException.java
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions
=> exception/buffer}/package-info.java (93%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions/TransactionBufferException.java
=> exception/coordinator/TransactionCoordinatorException.java} (51%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions
=> exception/coordinator}/package-info.java (92%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions
=> exception}/package-info.java (93%)
rename
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions/TransactionBufferException.java
=> exception/pendingack/TransactionPendingAckException.java} (58%)
rename
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/{buffer/exceptions
=> exception/pendingack}/package-info.java (92%)
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/exceptions/TransactionPendingAckStoreProviderException.java
