moved StatsType to stats module

thingsboard · Jan 10, 2025 · a68185a · a68185a
1 parent 6670f4a
commit a68185a
Show file tree

Hide file tree

Showing 10 changed files with 10 additions and 2 deletions.
diff --git a/...main/java/org/thingsboard/mqtt/broker/service/stats/DefaultApplicationProcessorStats.java b/...main/java/org/thingsboard/mqtt/broker/service/stats/DefaultApplicationProcessorStats.java
@@ -19,6 +19,7 @@
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsCounter;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 import org.thingsboard.mqtt.broker.service.mqtt.persistence.application.processing.ApplicationPackProcessingResult;
 
 import java.util.List;

diff --git a/...tion/src/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultClientActorStats.java b/...tion/src/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultClientActorStats.java
@@ -20,6 +20,7 @@
 import org.thingsboard.mqtt.broker.actors.shared.TimedMsg;
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;

diff --git a/...ava/org/thingsboard/mqtt/broker/service/stats/DefaultClientSessionEventConsumerStats.java b/...ava/org/thingsboard/mqtt/broker/service/stats/DefaultClientSessionEventConsumerStats.java
@@ -18,6 +18,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;

diff --git a/...ava/org/thingsboard/mqtt/broker/service/stats/DefaultClientSubscriptionConsumerStats.java b/...ava/org/thingsboard/mqtt/broker/service/stats/DefaultClientSubscriptionConsumerStats.java
@@ -17,6 +17,7 @@
 
 import org.thingsboard.mqtt.broker.common.stats.StatsCounter;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 
 import java.util.List;
 

diff --git a/.../src/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultDeviceProcessorStats.java b/.../src/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultDeviceProcessorStats.java
@@ -19,6 +19,7 @@
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsCounter;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 import org.thingsboard.mqtt.broker.service.mqtt.persistence.device.processing.DevicePackProcessingResult;
 import org.thingsboard.mqtt.broker.service.mqtt.persistence.device.processing.DevicePublishMsgListAndPrevPacketId;
 

diff --git a/...c/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultPublishMsgConsumerStats.java b/...c/main/java/org/thingsboard/mqtt/broker/service/stats/DefaultPublishMsgConsumerStats.java
@@ -19,6 +19,7 @@
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsCounter;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 import org.thingsboard.mqtt.broker.service.processing.PackProcessingResult;
 
 import java.util.List;

diff --git a/.../main/java/org/thingsboard/mqtt/broker/service/stats/DefaultRetainedMsgConsumerStats.java b/.../main/java/org/thingsboard/mqtt/broker/service/stats/DefaultRetainedMsgConsumerStats.java
@@ -17,6 +17,7 @@
 
 import org.thingsboard.mqtt.broker.common.stats.StatsCounter;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 
 import java.util.List;
 

diff --git a/application/src/main/java/org/thingsboard/mqtt/broker/service/stats/StatsManagerImpl.java b/application/src/main/java/org/thingsboard/mqtt/broker/service/stats/StatsManagerImpl.java
@@ -32,6 +32,7 @@
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsConstantNames;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 import org.thingsboard.mqtt.broker.dao.sql.SqlQueueStatsManager;
 import org.thingsboard.mqtt.broker.queue.TbQueueCallback;
 import org.thingsboard.mqtt.broker.queue.TbQueueMsgMetadata;

diff --git a/application/src/main/java/org/thingsboard/mqtt/broker/service/stats/timer/TimerStats.java b/application/src/main/java/org/thingsboard/mqtt/broker/service/stats/timer/TimerStats.java
@@ -17,7 +17,7 @@
 
 import org.thingsboard.mqtt.broker.common.stats.ResettableTimer;
 import org.thingsboard.mqtt.broker.common.stats.StatsFactory;
-import org.thingsboard.mqtt.broker.service.stats.StatsType;
+import org.thingsboard.mqtt.broker.common.stats.StatsType;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/.../mqtt/broker/service/stats/StatsType.java → ...d/mqtt/broker/common/stats/StatsType.java b/.../mqtt/broker/service/stats/StatsType.java → ...d/mqtt/broker/common/stats/StatsType.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.thingsboard.mqtt.broker.service.stats;
+package org.thingsboard.mqtt.broker.common.stats;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;