[feat][broker] Implement topic-level delayed delivery tracking with in-memory manager - #24927

Open

Denovo1998 wants to merge 16 commits into

apache:masterfrom

Denovo1998:topic_delayed_message

Commits on Oct 30, 2025

[feat][broker] Implement topic-level delayed delivery tracking with in-memory manager
Denovo1998
committed
fc876b7

Commits on Nov 1, 2025

feat[broker] Enhance InMemoryTopicDelayedDeliveryTrackerManager with fixed-delay detection and memory optimization
Denovo1998
committed
dee4363
[feat][broker] Improve InMemoryTopicDelayedDeliveryTrackerManager with enhanced memory management and concurrency controls
Denovo1998
committed
e455512
feat[broker] Add pruning mechanism and improve timestamp handling in InMemoryTopicDelayedDeliveryTrackerManager
Denovo1998
committed
60f6bcd
[feat][broker] Refactor delayedMessageMap to use Long2ObjectRBTreeMap for improved performance and memory efficiency
Denovo1998
committed
2c30c94
[feat][broker] Refactor mark-delete handling in InMemoryTopicDelayedDeliveryTrackerManager for event-driven updates and improved performance
Denovo1998
committed
6fd6ead
feat[broker] Simplify InMemoryTopicDelayedDeliveryTrackerManager by removing deprecated constructor and methods for improved clarity
Denovo1998
committed
6784c43
feat[broker] Add testing-friendly constructor and accessors to InMemoryDelayedDeliveryTrackerFactory for improved testability
Denovo1998
committed
701ffbf
[feat][broker] Refactor timestamp handling and bucket logic in InMemoryTopicDelayedDeliveryTrackerManager for improved accuracy and performance
Denovo1998
committed
c74a879
[feat][broker] Remove deprecated methods and simplify test annotations in InMemoryTopicDelayedDeliveryTrackerManager for improved clarity and maintainability
Denovo1998
committed
e576c65
[feat][broker] Replace highestDeliveryTimeTracked with AtomicLong for thread-safe updates and improve concurrency handling in InMemoryTopicDelayedDeliveryTrackerManager
Denovo1998
committed
938e4f6

Navigation Menu

[feat][broker] Implement topic-level delayed delivery tracking with in-memory manager - #24927

[feat][broker] Implement topic-level delayed delivery tracking with in-memory manager#24927
Denovo1998 wants to merge 16 commits into
apache:masterfrom
Denovo1998:topic_delayed_message

Commits on Oct 30, 2025

[feat][broker] Implement topic-level delayed delivery tracking with in-memory manager

Commits on Nov 1, 2025

feat[broker] Enhance InMemoryTopicDelayedDeliveryTrackerManager with fixed-delay detection and memory optimization

[feat][broker] Improve InMemoryTopicDelayedDeliveryTrackerManager with enhanced memory management and concurrency controls

feat[broker] Add pruning mechanism and improve timestamp handling in InMemoryTopicDelayedDeliveryTrackerManager

[feat][broker] Refactor delayedMessageMap to use Long2ObjectRBTreeMap for improved performance and memory efficiency

[feat][broker] Refactor mark-delete handling in InMemoryTopicDelayedDeliveryTrackerManager for event-driven updates and improved performance

feat[broker] Simplify InMemoryTopicDelayedDeliveryTrackerManager by removing deprecated constructor and methods for improved clarity

feat[broker] Add testing-friendly constructor and accessors to InMemoryDelayedDeliveryTrackerFactory for improved testability

[feat][broker] Refactor timestamp handling and bucket logic in InMemoryTopicDelayedDeliveryTrackerManager for improved accuracy and performance

[feat][broker] Remove deprecated methods and simplify test annotations in InMemoryTopicDelayedDeliveryTrackerManager for improved clarity and maintainability

[feat][broker] Replace highestDeliveryTimeTracked with AtomicLong for thread-safe updates and improve concurrency handling in InMemoryTopicDelayedDeliveryTrackerManager

Commits on Nov 2, 2025

[feat][broker] Introduce InMemoryTopicDelayedDeliveryTrackerFactory for topic-level delayed message tracking and update related configurations

[feat][broker] Add configuration options for in-memory topic-level delayed delivery tracker and rename view class for clarity

[feat][broker] Replace manual wait loops with Awaitility for pruning tests in InMemoryTopicDelayedDeliveryTrackerTest

[feat][broker] Update documentation for InMemoryTopicDelayedDeliveryTrackerFactory and related configurations to clarify memory usage and implementation details

feat[broker] Centralize mark-delete propagation to topic-level delayed tracker across dispatcher implementations