This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 964f51738f2 Update pyproject.toml (#17296)
add 6d9e6d0622a Subscription: support consumer timeout and idle disconnect
(#17293)
No new revisions were added by this update.
Summary of changes:
.../rpc/subscription/config/ConsumerConfig.java | 12 ++
.../rpc/subscription/config/ConsumerConstant.java | 3 +
.../iotdb/session/AbstractSessionBuilder.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 1 +
.../subscription/SubscriptionSessionWrapper.java | 2 +-
.../SubscriptionTableSessionBuilder.java | 5 +
.../SubscriptionTreeSessionBuilder.java | 5 +
.../base/AbstractSubscriptionConsumer.java | 16 ++-
.../base/AbstractSubscriptionConsumerBuilder.java | 7 +
.../base/AbstractSubscriptionProvider.java | 22 +++-
.../AbstractSubscriptionPullConsumerBuilder.java | 7 +
.../AbstractSubscriptionPushConsumerBuilder.java | 7 +
.../consumer/table/SubscriptionTableProvider.java | 20 ++-
.../table/SubscriptionTablePullConsumer.java | 13 +-
.../SubscriptionTablePullConsumerBuilder.java | 7 +
.../table/SubscriptionTablePushConsumer.java | 13 +-
.../SubscriptionTablePushConsumerBuilder.java | 7 +
.../consumer/tree/SubscriptionTreeProvider.java | 20 ++-
.../tree/SubscriptionTreePullConsumer.java | 20 ++-
.../tree/SubscriptionTreePullConsumerBuilder.java | 7 +
.../tree/SubscriptionTreePushConsumer.java | 20 ++-
.../tree/SubscriptionTreePushConsumerBuilder.java | 7 +
.../agent/SubscriptionReceiverAgent.java | 26 +++-
.../receiver/SubscriptionReceiver.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 144 ++++++++++++++++-----
.../receiver/SubscriptionReceiverV1Test.java | 114 ++++++++++++++++
26 files changed, 456 insertions(+), 52 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1Test.java
