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 4f7c9ab Fix admin-api-namespaces page grammatical errors (#7779)
add 6e7d1a8 [Transaction] Support consume transaction messages. (#7781)
No new revisions were added by this update.
Summary of changes:
.../broker/service/AbstractBaseDispatcher.java | 23 ++-
.../PersistentDispatcherMultipleConsumers.java | 5 +
.../PersistentDispatcherSingleActiveConsumer.java | 7 +-
.../service/persistent/TransactionReader.java | 140 ++++++++++++++++++
.../transaction/buffer/TransactionEntry.java | 7 +-
.../buffer/impl/InMemTransactionBufferReader.java | 4 +-
.../impl/PersistentTransactionBufferReader.java | 4 +-
.../buffer/impl/TransactionEntryImpl.java | 17 ++-
.../buffer/impl/TransactionMetaImpl.java | 2 +-
.../broker/transaction/TransactionConsumeTest.java | 163 +++++++++++++++++++++
...actionTest.java => TransactionProduceTest.java} | 4 +-
.../buffer/InMemTransactionBufferReaderTest.java | 2 +-
.../buffer/PersistentTransactionBufferTest.java | 7 +-
.../transaction/buffer/TransactionBufferTest.java | 2 +-
.../buffer/TransactionEntryImplTest.java | 5 +-
.../coordinator/TransactionMetaStoreTestBase.java | 2 +-
.../pulsar/client/transaction/EndToEndTest.java | 130 ++++++++++++++++
17 files changed, 497 insertions(+), 27 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/TransactionReader.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionConsumeTest.java
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/{PulsarClientTransactionTest.java
=> TransactionProduceTest.java} (98%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/transaction/EndToEndTest.java
