Yevhen Bondarenko
424d631a69
added extra properties to kafka consumer ( #2751 )
...
* added extra properties to kafka consumer
* added default values for kafka consumer properties in TbKafkaSettings
* Update TbKafkaSettings.java
* Update thingsboard.yml
Co-authored-by: Andrew Shvayka <ashvayka@thingsboard.io>
2020-05-08 14:38:04 +03:00
Andrii Shvaika
71f94358c4
Fix typos and added break statement
2020-05-07 10:49:44 +03:00
Andrii Shvaika
f07d7441b2
Change of the partition routing strategy
2020-05-05 16:11:10 +03:00
Andrii Shvaika
830d02ef6a
Fix for HTTP and CoAP device activity
2020-05-04 14:00:18 +03:00
Andrew Shvayka
c1b5fd5c57
Merge pull request #2714 from thingsboard/feature/queue-consumers-refactoring
...
Feature/queue consumers refactoring
2020-05-04 10:17:46 +03:00
YevhenBondarenko
00e32ee8a3
merge with feature/queue-consumers-refactoring
2020-05-04 09:39:04 +03:00
Volodymyr Babak
8dbc550fd3
Refactoring to review. Added tenantId and customerId. Added email tenant name strategy
2020-05-04 00:21:58 +03:00
Volodymyr Babak
a563fdab3f
Added basic and custom OAuth2 user mappers
2020-05-04 00:21:58 +03:00
Andrii Shvaika
08ab9752fc
Better logging of Rule Engine errors
2020-05-04 00:13:14 +03:00
Andrew Shvayka
e251bc5750
Improvement to deserialization and remove debug on dashboards
2020-05-02 18:12:43 +03:00
YevhenBondarenko
06c3caf082
refactored
2020-05-02 13:34:11 +03:00
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
09d8823205
Race condition fix
2020-04-30 20:38:53 +03:00
Andrii Shvaika
702a8b6139
Force unsubscribe from Kafka topics
2020-04-30 18:10:05 +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
Andrew Shvayka
7a47cd503b
Revert "Develop/2.5 js executor ( #2685 )"
...
This reverts commit 1599b24c3a748599a84f877987f452579c997ccf.
2020-04-30 11:19:50 +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
Andrii Shvaika
a38ee80e09
Refactoring of device creation using gateway
2020-04-29 10:02:00 +03:00
Andrii Shvaika
79b4411c69
Synchronization of device connect processing in gateways
2020-04-29 09:45:24 +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
bdrlamb
cb6e91277f
Fix MQTT inactivity disconnects
...
MQTT clients don't send PINGREQ messages if they've recently sent [UN]SUBSCRIBE/PUBLISH messages. The MQTT server last activity timestamp is currently only updated in response to PINGREQ messages. This causes the server to disconnect any clients that regularly send PUBLISH messages since they don't send PINGREQ.
This change adds reportActivity calls in response to PUBLISH, SUBSCRIBE and UNSUBSCRIBE in addition to PINGREQ.
2020-04-28 14:15:57 +03:00
Andrii Shvaika
8abb718349
Merge with develop
2020-04-28 14:09:20 +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
a779839081
Fixed transport
2020-04-24 19:16:25 +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
Andrii Shvaika
9ee0b34f0d
Merge remote-tracking branch 'origin/develop/2.5' into develop/2.5
2020-04-20 11:02:58 +03:00
Andrii Shvaika
b1f87206f3
Minor improvements
2020-04-20 11:02:40 +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
e991c0ef23
No more Synchronization nodes
2020-04-14 08:44:34 +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
hamza.slama
5b8ce2fb69
Move AlarmId To Id Package
2020-04-13 10:40:03 +03:00
Yevhen Bondarenko
7869fb5ef4
added to tenant fields isolatedTbCore and isolatedTbRuleEngine ( #2611 )
...
Co-authored-by: Andrew Shvayka <ashvayka@thingsboard.io>
2020-04-13 10:24:40 +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