This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch
feature/initial-retain-progress-after-unsubscribe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f3d9020835b Support progress retention for initial subscription topics
add 3a8557836b0 Fix retained initial subscription replay and recovery
No new revisions were added by this update.
Summary of changes:
.../subscription/topic/DropTopicProcedure.java | 1 +
.../subscription/topic/DropTopicProcedureTest.java | 38 +++
.../agent/SubscriptionBrokerAgent.java | 6 +-
.../agent/SubscriptionConsumerAgent.java | 11 +-
.../db/subscription/broker/SubscriptionBroker.java | 22 +-
.../broker/SubscriptionPrefetchingQueue.java | 28 ++
.../db/subscription/event/SubscriptionEvent.java | 6 +
.../agent/SubscriptionConsumerAgentTest.java | 2 +-
.../SubscriptionRetainedInitialReplayTest.java | 328 +++++++++++++++++++++
9 files changed, 430 insertions(+), 12 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionRetainedInitialReplayTest.java
