170 Commits

Author SHA1 Message Date
Andrii Shvaika
8d5c38b743 Queue refactoring 2020-05-01 17:43:13 +03:00
YevhenBondarenko
eedb383845 AWS improvements 2020-05-01 14:15:31 +03:00
Andrii Shvaika
c7f282d393 Refactoring of the Queue Consumers 2020-05-01 12:45:06 +03:00
Andrii Shvaika
c6cf5c43ad Merge remote-tracking branch 'origin/master' into develop/3.0 2020-04-30 20:40:08 +03:00
Andrii Shvaika
09d8823205 Race condition fix 2020-04-30 20:38:53 +03:00
Andrii Shvaika
d866fc1503 Merge remote-tracking branch 'origin/master' into develop/3.0 2020-04-30 18:11:56 +03:00
Andrii Shvaika
702a8b6139 Force unsubscribe from Kafka topics 2020-04-30 18:10:05 +03:00
Igor Kulikov
8b5793f203 Merge branch 'master' of github.com:thingsboard/thingsboard into develop/3.0 2020-04-30 15:39:00 +03:00
Andrii Shvaika
beb5d1d0ba Merge branch 'develop/2.5-js-executor' of https://github.com/YevhenBondarenko/thingsboard 2020-04-30 15:08:05 +03:00
Andrii Shvaika
5034fd6d37 Merge branch 'master' into develop/3.0 2020-04-30 11:21:34 +03:00
Andrew Shvayka
7a47cd503b Revert "Develop/2.5 js executor (#2685)"
This reverts commit 1599b24c3a748599a84f877987f452579c997ccf.
2020-04-30 11:19:50 +03:00
Igor Kulikov
6894b19b87 Merge with master 2020-04-30 09:46:07 +03:00
Yevhen Bondarenko
1599b24c3a
Develop/2.5 js executor (#2685)
* moved kafka from service.js to own module

* created awsSqs, pubSub, rabbitmq js-executors

* revert RemoteJsInvokeService

* revert thingsboard.yml

* added queue settings to js-executor

* refactored queue factories

* added queue params to pubsub js-executor

* azure service bus js-executor
2020-04-29 21:02:47 +03:00
YevhenBondarenko
43b2eedbd5 azure service bus js-executor 2020-04-29 18:27:53 +03:00
YevhenBondarenko
cce6a44adc refactored queue factories 2020-04-29 10:14:05 +03:00
Igor Kulikov
a4cd853a20 Merge branch 'master' of github.com:thingsboard/thingsboard into develop/3.0 2020-04-28 18:48:44 +03:00
Andrii Shvaika
eb3cc332d1 Fix gateway/device last activity time checks 2020-04-28 18:19:30 +03:00
YevhenBondarenko
6322da3d04 merge with master 2020-04-28 16:51:04 +03:00
YevhenBondarenko
0dc31fbdde created awsSqs, pubSub, rabbitmq js-executors 2020-04-28 16:13:16 +03:00
Igor Kulikov
45f3d5324e Merge branch 'master' of github.com:thingsboard/thingsboard into develop/3.0 2020-04-28 14:29:02 +03:00
Andrii Shvaika
8abb718349 Merge with develop 2020-04-28 14:09:20 +03:00
Andrii Shvaika
2728c7cd29 Merge remote-tracking branch 'origin/master' into develop/3.0 2020-04-27 14:45:18 +03:00
Andrii Shvaika
86f21023fe Improved PartitionService and fixed startup order in docker-compose.yml 2020-04-27 14:44:29 +03:00
YevhenBondarenko
ba140644c7 added Azure Service Bus queue settings 2020-04-27 11:16:53 +03:00
Andrii Shvaika
91aa7a2700 Merge with master (2.5) 2020-04-27 00:40:21 +03:00
Andrew Shvayka
38ebbe2576 Revert "Merge with master. AlarmRepository.findAlarms is failing (#2663)"
This reverts commit 2c02406ee5f41b08e655b634dd9871403f67149d.
2020-04-24 19:42:32 +03:00
Andrew Shvayka
2c02406ee5
Merge with master. AlarmRepository.findAlarms is failing (#2663)
* Merge with master. AlarmRepository.findAlarms is failing

* Fix Alarm repository. Add queue type list select.

Co-authored-by: Igor Kulikov <ikulikov@thingsboard.io>
2020-04-24 15:44:31 +03:00
Andrii Shvaika
53eb09bcb9 Improvements to tests due to new architecture 2020-04-21 22:31:25 +03:00
YevhenBondarenko
283ad27cb5 added rabbitmq queue arguments 2020-04-21 20:55:02 +03:00
YevhenBondarenko
2ad4ddf1fb pubsub improvements 2020-04-21 12:56:06 +03:00
YevhenBondarenko
1b9df18c45 created TbPubSubSubscriptionSettings 2020-04-21 12:56:06 +03:00
Andrii Shvaika
58d9c313a8 Fixed tests 2020-04-20 16:12:03 +03:00
YevhenBondarenko
12973cecf1 added method destroy to admins and aws sqs factories 2020-04-17 15:17:06 +03:00
YevhenBondarenko
9fa82078a0 created TbAwsSqsQueueAttributes and added queue properties to yml 2020-04-17 15:17:06 +03:00
Yevhen Bondarenko
d654e09d6a
kafka topic settings
* added topic-properties to kafka queue

* added topic-properties to kafka queue to transport

* kafka topic settings improvements
2020-04-15 17:47:46 +03:00
Andrii Shvaika
0c54f836b3 Fixed tests 2020-04-14 16:17:08 +03:00
Andrii Shvaika
63bac58ae8 Implementation of statistics counters 2020-04-14 08:27:44 +03:00
Andrii Shvaika
d380ac7106 Device -> Server RPC implementation and improvements 2020-04-13 18:33:11 +03:00
Andrii Shvaika
6c4b50a380 Implemented dedicated RE per tenant 2020-04-13 14:59:48 +03:00
Yevhen Bondarenko
8442159811
[2.5] vulnerabilities (#2608)
* Version updates

* added @Retention(RetentionPolicy.RUNTIME) for all custom Dao annotations.

* changed getId, setId to getUuid, setUuid from BaseEntity, improvement AbstractControllerTest

* fix rabbitmq

* fix RuleChainManagerActor

* refactored InMemory queue

Co-authored-by: Andrii Shvaika <ashvayka@thingsboard.io>
2020-04-13 09:34:35 +03:00
YevhenBondarenko
1dd3334825 moved jsinvoke.proto to queue, fixed js-executor, added createRemoteJsRequestTemplate to RuleEngine and Core factories 2020-04-10 12:52:05 +03:00
Yevhen Bondarenko
7b3d475267
[2.5] created rabbitmq queue (#2589)
* created main classes for RabbitMq queue

* created temp version rabbitmq

* Merge branch 'develop/2.5' of https://github.com/thingsboard/thingsboard into develop/2.5-rabbitmq

# Conflicts:
#	common/queue/pom.xml

* rabbit improvements
2020-04-09 18:41:37 +03:00
Andrii Shvaika
ca193239ba RE Submit Strategies 2020-04-09 18:33:44 +03:00
Andrii Shvaika
ec4e2c036f No more failures on missing RE queue 2020-04-09 13:09:54 +03:00
Andrii Shvaika
2f6c6ad1fe Merge with master 2020-04-08 18:24:52 +03:00
Andrii Shvaika
c7b428fbc7 Merge branch 'develop/2.5' of github.com:thingsboard/thingsboard into develop/2.5 2020-04-08 14:10:14 +03:00
Andrii Shvaika
3eaae1ef32 Statistics Implementation 2020-04-08 14:09:56 +03:00
Yevhen Bondarenko
45bd764e6f
Azure ServiceBus queue
* created event hubs queue

* created servicebus queue

* refactored

* refactored
2020-04-07 11:45:28 +03:00
Andrii Shvaika
638ca0e1d1 Refactoring to multiple queues for rule engine 2020-04-06 18:35:43 +03:00
Yevhen Bondarenko
b39328c989
[2.5]fix ConcurrentModificationException (#2560)
* fix ConcurrentModificationException

* kafka consumer improvements

* kafka consumer improvements

* refactored kafka consumer

* refactored kafka consumer
2020-03-31 16:47:43 +03:00