You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bifromq.apache.org by po...@apache.org on 2026/10/29 09:00:59 UTC
(bifromq) branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5 updated (c3a34bd6d -> 3a52797f7)
This is an automated email from the ASF dual-hosted git repository.
popduke pushed a change to branch dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5
in repository https://gitbox.apache.org/repos/asf/bifromq.git
from c3a34bd6d Merge branch 'main' into dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5
add d1b6e7204 Check Will publish permission on connect (#276)
add 898bc4cf9 Fix duplicate local delivery results by prioritizing NO_RECEIVER (#278)
add ba2c34e01 Fix cleanup for dropped oversized MQTT packets (#279)
add eef5e3aff Apply isDup flag in MQTT5 buildMqttPubMessage (three builder paths) — fixes #283 (#284)
add 139413107 fix: preserve causality for future HLC updates (#295)
add f19c557d7 Fix MQTT packet size limits and message completion (#315)
add e279da423 Fix executor metrics lifecycle (#321)
add 2a7ae5f61 Fix Dist route ordering and Fact pruning (#323)
add 3a52797f7 Merge branch 'main' into dependabot/maven/org.apache.logging.log4j-log4j-api-2.25.5
No new revisions were added by this update.
Summary of changes:
.../org/apache/bifromq/basecluster/AgentHost.java | 11 +-
.../AgentHostExecutorLifecycleTest.java | 125 ++++
.../main/java/org/apache/bifromq/basehlc/HLC.java | 2 +-
.../java/org/apache/bifromq/basehlc/HLCTest.java | 9 +
base-kv/base-kv-local-engine-rocksdb/pom.xml | 4 +
.../localengine/rocksdb/RocksDBCPableKVSpace.java | 31 +-
.../basekv/localengine/rocksdb/RocksDBKVSpace.java | 13 +-
.../localengine/rocksdb/RocksDBWALableKVSpace.java | 31 +-
.../rocksdb/RocksDBExecutorLifecycleTest.java | 336 +++++++++++
.../org/apache/bifromq/basekv/raft/RaftNode.java | 4 +-
.../apache/bifromq/basekv/raft/RaftNodeTest.java | 28 +-
.../raft/functest/RaftConfigMigrationTest.java | 48 +-
.../basekv/store/range/KVRangeDumpSession.java | 2 +-
.../bifromq/basekv/store/range/KVRangeFSM.java | 10 +-
.../bifromq/basekv/store/KVRangeStoreTest.java | 17 +
.../basekv/store/range/KVRangeDumpSessionTest.java | 80 ++-
.../range/KVRangeFSMExecutorLifecycleTest.java | 120 ++++
.../bifromq/basekv/store/wal/KVRangeWALTest.java | 7 +-
base-util/pom.xml | 5 +
.../bifromq/base/util/MonitoredExecutors.java | 431 ++++++++++++++
.../base/util/MonitoredExecutorsExportTest.java | 128 ++++
.../bifromq/base/util/MonitoredExecutorsTest.java | 652 +++++++++++++++++++++
.../bifromq/dist/trie/NTopicFilterTrieNode.java | 5 +-
.../bifromq/dist/trie/STopicFilterTrieNode.java | 5 +-
.../bifromq/dist/trie/TopicFilterIterator.java | 5 +-
.../java/org/apache/bifromq/dist/TestUtil.java | 10 +-
.../bifromq/dist/trie/TopicFilterIteratorTest.java | 32 +-
.../bifromq/dist/trie/TopicFilterOrderTest.java | 101 ++++
.../server/scheduler/TenantRangeLookupCache.java | 19 +-
.../scheduler/TenantRangeLookupCacheTest.java | 53 +-
.../dist/worker/schema/KVSchemaConstants.java | 1 +
.../bifromq/dist/worker/schema/KVSchemaUtil.java | 4 +-
.../bifromq/dist/worker/schema/RouteKeyOrder.java | 104 ++++
.../dist/worker/schema/cache/RouteDetailCache.java | 20 +-
.../dist/worker/schema/KVSchemaUtilTest.java | 33 ++
.../dist/worker/schema/RouteKeyOrderTest.java | 134 +++++
bifromq-dist/bifromq-dist-worker/pom.xml | 4 +
.../apache/bifromq/dist/worker/Comparators.java | 23 +-
.../bifromq/dist/worker/DeliverExecutor.java | 10 +-
.../bifromq/dist/worker/DeliverExecutorGroup.java | 5 +-
.../bifromq/dist/worker/DistWorkerCoProc.java | 68 ++-
.../dist/worker/DistWorkerCoProcFactory.java | 3 +-
.../bifromq/dist/worker/ComparatorsTest.java | 9 +-
.../dist/worker/DeliverExecutorLifecycleTest.java | 87 +++
.../apache/bifromq/dist/worker/DistQoS0Test.java | 52 +-
.../dist/worker/DistWorkerFactOrderTest.java | 227 +++++++
.../dist/worker/cache/TenantRouteMatcherTest.java | 46 ++
.../bifromq/inbox/store/InboxStoreCoProc.java | 2 +-
.../bifromq/inbox/store/delay/DelayTaskRunner.java | 24 +-
.../inbox/store/delay/IDelayTaskRunner.java | 2 +-
.../store/delay/DelayTaskRunnerLifecycleTest.java | 148 +++++
.../inbox/store/delay/DelayTaskRunnerTest.java | 28 +-
.../apache/bifromq/mqtt/handler/ChannelAttrs.java | 15 +-
.../bifromq/mqtt/handler/MQTTConnectHandler.java | 29 +
.../bifromq/mqtt/handler/MQTTPacketFilter.java | 3 +
.../bifromq/mqtt/handler/MQTTSessionHandler.java | 83 ++-
.../mqtt/handler/OversizePacketException.java | 13 +-
.../mqtt/handler/v3/MQTT3ConnectHandler.java | 45 ++
.../mqtt/handler/v5/MQTT5ConnectHandler.java | 55 ++
.../mqtt/handler/v5/MQTT5ProtocolHelper.java | 5 +-
.../bifromq/mqtt/service/LocalDistService.java | 1 +
.../bifromq/mqtt/handler/ChannelAttrsTest.java | 113 ++++
.../bifromq/mqtt/handler/MQTTPacketFilterTest.java | 84 ++-
.../bifromq/mqtt/handler/v3/BaseMQTTTest.java | 4 +
.../v3/MQTT3PersistentSessionHandlerTest.java | 104 +++-
.../v3/MQTT3TransientSessionHandlerTest.java | 179 ++++++
.../bifromq/mqtt/handler/v3/MQTTConnectTest.java | 58 ++
.../mqtt/handler/v3/MQTTWillMessageTest.java | 12 +-
.../mqtt/handler/v5/ConnectHandlerTest.java | 94 ++-
.../handler/v5/PersistentSessionHandlerTest.java | 102 +++-
.../handler/v5/TransientSessionHandlerTest.java | 152 +++++
.../bifromq/mqtt/integration/v5/PubSubTest.java | 10 +
.../bifromq/mqtt/service/LocalDistServiceTest.java | 46 ++
.../bifromq/plugin/settingprovider/Setting.java | 3 +-
.../plugin/settingprovider/SettingTest.java | 11 +
75 files changed, 4335 insertions(+), 244 deletions(-)
create mode 100644 base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostExecutorLifecycleTest.java
create mode 100644 base-kv/base-kv-local-engine-rocksdb/src/test/java/org/apache/bifromq/basekv/localengine/rocksdb/RocksDBExecutorLifecycleTest.java
create mode 100644 base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/range/KVRangeFSMExecutorLifecycleTest.java
create mode 100644 base-util/src/main/java/org/apache/bifromq/base/util/MonitoredExecutors.java
create mode 100644 base-util/src/test/java/org/apache/bifromq/base/util/MonitoredExecutorsExportTest.java
create mode 100644 base-util/src/test/java/org/apache/bifromq/base/util/MonitoredExecutorsTest.java
create mode 100644 bifromq-dist/bifromq-dist-coproc-proto/src/test/java/org/apache/bifromq/dist/trie/TopicFilterOrderTest.java
create mode 100644 bifromq-dist/bifromq-dist-worker-schema/src/main/java/org/apache/bifromq/dist/worker/schema/RouteKeyOrder.java
create mode 100644 bifromq-dist/bifromq-dist-worker-schema/src/test/java/org/apache/bifromq/dist/worker/schema/RouteKeyOrderTest.java
create mode 100644 bifromq-dist/bifromq-dist-worker/src/test/java/org/apache/bifromq/dist/worker/DeliverExecutorLifecycleTest.java
create mode 100644 bifromq-dist/bifromq-dist-worker/src/test/java/org/apache/bifromq/dist/worker/DistWorkerFactOrderTest.java
create mode 100644 bifromq-inbox/bifromq-inbox-store/src/test/java/org/apache/bifromq/inbox/store/delay/DelayTaskRunnerLifecycleTest.java
copy base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/KVEngineException.java => bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/OversizePacketException.java (73%)
create mode 100644 bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/ChannelAttrsTest.java