06c3caf082
refactored
6 years ago
8d5c38b743
Queue refactoring
6 years ago
eedb383845
AWS improvements
6 years ago
c7f282d393
Refactoring of the Queue Consumers
6 years ago
09d8823205
Race condition fix
6 years ago
702a8b6139
Force unsubscribe from Kafka topics
6 years ago
7a47cd503b
Revert "Develop/2.5 js executor ( #2685 )"
This reverts commit 1599b24c3a
6 years ago
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
6 years ago
43b2eedbd5
azure service bus js-executor
6 years ago
cce6a44adc
refactored queue factories
6 years ago
eb3cc332d1
Fix gateway/device last activity time checks
6 years ago
0dc31fbdde
created awsSqs, pubSub, rabbitmq js-executors
6 years ago
86f21023fe
Improved PartitionService and fixed startup order in docker-compose.yml
6 years ago
ba140644c7
added Azure Service Bus queue settings
6 years ago
53eb09bcb9
Improvements to tests due to new architecture
6 years ago
283ad27cb5
added rabbitmq queue arguments
6 years ago
2ad4ddf1fb
pubsub improvements
6 years ago
1b9df18c45
created TbPubSubSubscriptionSettings
6 years ago
58d9c313a8
Fixed tests
6 years ago
12973cecf1
added method destroy to admins and aws sqs factories
6 years ago
9fa82078a0
created TbAwsSqsQueueAttributes and added queue properties to yml
6 years ago
d654e09d6a
kafka topic settings
* added topic-properties to kafka queue
* added topic-properties to kafka queue to transport
* kafka topic settings improvements
6 years ago
0c54f836b3
Fixed tests
6 years ago
63bac58ae8
Implementation of statistics counters
6 years ago
d380ac7106
Device -> Server RPC implementation and improvements
6 years ago
6c4b50a380
Implemented dedicated RE per tenant
6 years ago
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>
6 years ago
1dd3334825
moved jsinvoke.proto to queue, fixed js-executor, added createRemoteJsRequestTemplate to RuleEngine and Core factories
6 years ago
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
6 years ago
ca193239ba
RE Submit Strategies
6 years ago
ec4e2c036f
No more failures on missing RE queue
6 years ago
3eaae1ef32
Statistics Implementation
6 years ago
45bd764e6f
Azure ServiceBus queue
* created event hubs queue
* created servicebus queue
* refactored
* refactored
6 years ago
638ca0e1d1
Refactoring to multiple queues for rule engine
6 years ago
b39328c989
[2.5]fix ConcurrentModificationException ( #2560 )
* fix ConcurrentModificationException
* kafka consumer improvements
* kafka consumer improvements
* refactored kafka consumer
* refactored kafka consumer
6 years ago
a6e090ef86
Develop/2.5 pubsub ( #2566 )
* created Aws Sqs Queue
* improvement AwsSqs providers
* created pubsub queue
* revert package-lock.json
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Created pubsub queue
* aws improvements
* aws improvements
* aws improvements
* added visibility timeout to aws queue
* pub sub improvements
* pub sub improvements
* aws sqs improvements
* pub sub improvements
* added comment to transport.yml about ack deadline
6 years ago
2553cf6b6f
created Aws Sqs Queue ( #2534 )
* created Aws Sqs Queue
* improvement AwsSqs providers
* revert package-lock.json
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* Aws sqs improvements
* aws improvements
* aws improvements
* aws improvements
* added visibility timeout to aws queue
6 years ago
c4269023dd
Fixed Conditional annotations
6 years ago
6fe25a2ee2
Refactoring to support TB-Rule-Engine service
6 years ago
7531a26e61
Implementation of RPC Call support
6 years ago
2ccce3b6d9
Main Logic of RuleChainActor to handle queue messages
6 years ago
99d322d449
Refactoring of the rule engine
6 years ago
ce6ec88983
Refactoring of the websocket and subscription services
6 years ago
e102b55bc1
Thread-safety usage of Kafka Consumer
6 years ago
7203e7aa19
Distributed Mode fixes
6 years ago
94eb213716
Implementation
6 years ago
7de485f453
Kafka configuration
6 years ago
2a815058e7
Improvements and bugfix to QueueProviders
6 years ago
23c017567b
Implementation of Queue Interfaces
6 years ago
e50796d84e
Service Discovery improvements
6 years ago
YevhenBondarenko
Andrii Shvaika
Yevhen Bondarenko