thingsboard-aplcache

Cleanup

5/24/2018 4:18:06 AM

Igor Kulikov

Commit: 02e2c14

Tree: 8aeda75

Parents: d1552a1

Changes

application/src/main/resources/thingsboard.yml 2(+1 -1)

dao/src/main/java/org/thingsboard/server/dao/queue/db/MsgAck.java 32(+0 -32)

dao/src/main/java/org/thingsboard/server/dao/queue/db/nosql/CassandraMsgQueue.java 87(+0 -87)

dao/src/main/java/org/thingsboard/server/dao/queue/db/nosql/QueuePartitioner.java 86(+0 -86)

dao/src/main/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraAckRepository.java 68(+0 -68)

dao/src/main/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraMsgRepository.java 67(+0 -67)

dao/src/main/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraProcessedPartitionRepository.java 64(+0 -64)

dao/src/main/java/org/thingsboard/server/dao/queue/db/repository/AckRepository.java 29(+0 -29)

dao/src/main/java/org/thingsboard/server/dao/queue/db/repository/MsgRepository.java 30(+0 -30)

dao/src/main/java/org/thingsboard/server/dao/queue/db/repository/ProcessedPartitionRepository.java 29(+0 -29)

dao/src/main/java/org/thingsboard/server/dao/queue/db/sql/SqlMsgQueue.java 20(+0 -20)

dao/src/main/java/org/thingsboard/server/dao/queue/db/UnprocessedMsgFilter.java 35(+0 -35)

dao/src/test/java/org/thingsboard/server/dao/queue/db/nosql/QueuePartitionerTest.java 81(+0 -81)

dao/src/test/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraAckRepositoryTest.java 82(+0 -82)

dao/src/test/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraMsgRepositoryTest.java 87(+0 -87)

dao/src/test/java/org/thingsboard/server/dao/queue/db/nosql/repository/CassandraProcessedPartitionRepositoryTest.java 83(+0 -83)

dao/src/test/java/org/thingsboard/server/dao/queue/db/nosql/UnprocessedMsgFilterTest.java 47(+0 -47)

Details

application/src/main/resources/thingsboard.yml 2(+1 -1)

diff --git a/application/src/main/resources/thingsboard.yml b/application/src/main/resources/thingsboard.yml
index a10ef7d..188291a 100644
--- a/application/src/main/resources/thingsboard.yml
+++ b/application/src/main/resources/thingsboard.yml
@@ -257,7 +257,7 @@ actors:
       # Errors for particular actor are persisted once per specified amount of milliseconds
       error_persist_frequency: "${ACTORS_RULE_NODE_ERROR_FREQUENCY:3000}"
     queue:
-      # Message queue type (memory or db)
+      # Message queue type
       type: "${ACTORS_RULE_QUEUE_TYPE:memory}"
       # Message queue maximum size (per tenant)
       max_size: "${ACTORS_RULE_QUEUE_MAX_SIZE:100}"