Commit e684c267962fce252c276f3d539c402d0f73c5ac

Authored by Andrew Shvayka
1 parent 571f96c4

New Buffered Rate Limit implementation

@@ -22,8 +22,8 @@ import lombok.extern.slf4j.Slf4j; @@ -22,8 +22,8 @@ import lombok.extern.slf4j.Slf4j;
22 import org.springframework.beans.factory.annotation.Value; 22 import org.springframework.beans.factory.annotation.Value;
23 import org.springframework.scheduling.annotation.Scheduled; 23 import org.springframework.scheduling.annotation.Scheduled;
24 import org.springframework.stereotype.Component; 24 import org.springframework.stereotype.Component;
25 -import org.thingsboard.server.dao.nosql.tmp.AbstractBufferedRateExecutor;  
26 -import org.thingsboard.server.dao.nosql.tmp.AsyncTaskContext; 25 +import org.thingsboard.server.dao.util.AbstractBufferedRateExecutor;
  26 +import org.thingsboard.server.dao.util.AsyncTaskContext;
27 import org.thingsboard.server.dao.util.NoSqlAnyDao; 27 import org.thingsboard.server.dao.util.NoSqlAnyDao;
28 28
29 import javax.annotation.PreDestroy; 29 import javax.annotation.PreDestroy;
@@ -18,7 +18,7 @@ package org.thingsboard.server.dao.nosql; @@ -18,7 +18,7 @@ package org.thingsboard.server.dao.nosql;
18 import com.datastax.driver.core.Session; 18 import com.datastax.driver.core.Session;
19 import com.datastax.driver.core.Statement; 19 import com.datastax.driver.core.Statement;
20 import lombok.Data; 20 import lombok.Data;
21 -import org.thingsboard.server.dao.nosql.tmp.AsyncTask; 21 +import org.thingsboard.server.dao.util.AsyncTask;
22 22
23 /** 23 /**
24 * Created by ashvayka on 24.10.18. 24 * Created by ashvayka on 24.10.18.
dao/src/main/java/org/thingsboard/server/dao/util/AbstractBufferedRateExecutor.java renamed from dao/src/main/java/org/thingsboard/server/dao/nosql/tmp/AbstractBufferedRateExecutor.java
@@ -13,7 +13,7 @@ @@ -13,7 +13,7 @@
13 * See the License for the specific language governing permissions and 13 * See the License for the specific language governing permissions and
14 * limitations under the License. 14 * limitations under the License.
15 */ 15 */
16 -package org.thingsboard.server.dao.nosql.tmp; 16 +package org.thingsboard.server.dao.util;
17 17
18 import com.google.common.util.concurrent.FutureCallback; 18 import com.google.common.util.concurrent.FutureCallback;
19 import com.google.common.util.concurrent.Futures; 19 import com.google.common.util.concurrent.Futures;
dao/src/main/java/org/thingsboard/server/dao/util/AsyncTask.java renamed from dao/src/main/java/org/thingsboard/server/dao/nosql/tmp/AsyncTask.java
@@ -13,7 +13,7 @@ @@ -13,7 +13,7 @@
13 * See the License for the specific language governing permissions and 13 * See the License for the specific language governing permissions and
14 * limitations under the License. 14 * limitations under the License.
15 */ 15 */
16 -package org.thingsboard.server.dao.nosql.tmp; 16 +package org.thingsboard.server.dao.util;
17 17
18 /** 18 /**
19 * Created by ashvayka on 24.10.18. 19 * Created by ashvayka on 24.10.18.
dao/src/main/java/org/thingsboard/server/dao/util/AsyncTaskContext.java renamed from dao/src/main/java/org/thingsboard/server/dao/nosql/tmp/AsyncTaskContext.java
@@ -13,7 +13,7 @@ @@ -13,7 +13,7 @@
13 * See the License for the specific language governing permissions and 13 * See the License for the specific language governing permissions and
14 * limitations under the License. 14 * limitations under the License.
15 */ 15 */
16 -package org.thingsboard.server.dao.nosql.tmp; 16 +package org.thingsboard.server.dao.util;
17 17
18 import com.google.common.util.concurrent.SettableFuture; 18 import com.google.common.util.concurrent.SettableFuture;
19 import lombok.Data; 19 import lombok.Data;
dao/src/main/java/org/thingsboard/server/dao/util/BufferedRateExecutor.java renamed from dao/src/main/java/org/thingsboard/server/dao/nosql/tmp/BufferedRateExecutor.java
@@ -13,7 +13,7 @@ @@ -13,7 +13,7 @@
13 * See the License for the specific language governing permissions and 13 * See the License for the specific language governing permissions and
14 * limitations under the License. 14 * limitations under the License.
15 */ 15 */
16 -package org.thingsboard.server.dao.nosql.tmp; 16 +package org.thingsboard.server.dao.util;
17 17
18 import com.google.common.util.concurrent.ListenableFuture; 18 import com.google.common.util.concurrent.ListenableFuture;
19 19