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
6 years ago
Andrii Shvaika
ca193239ba
RE Submit Strategies
6 years ago
Andrii Shvaika
ec4e2c036f
No more failures on missing RE queue
6 years ago
Andrii Shvaika
3eaae1ef32
Statistics Implementation
6 years ago
Yevhen Bondarenko
45bd764e6f
Azure ServiceBus queue
* created event hubs queue
* created servicebus queue
* refactored
* refactored
6 years ago
Andrii Shvaika
638ca0e1d1
Refactoring to multiple queues for rule engine
6 years ago
Yevhen Bondarenko
b39328c989
[2.5]fix ConcurrentModificationException ( #2560 )
* fix ConcurrentModificationException
* kafka consumer improvements
* kafka consumer improvements
* refactored kafka consumer
* refactored kafka consumer
6 years ago
Yevhen Bondarenko
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
Yevhen Bondarenko
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
Andrii Shvaika
c4269023dd
Fixed Conditional annotations
6 years ago
Andrii Shvaika
6fe25a2ee2
Refactoring to support TB-Rule-Engine service
6 years ago
Andrii Shvaika
7531a26e61
Implementation of RPC Call support
6 years ago
Andrii Shvaika
2ccce3b6d9
Main Logic of RuleChainActor to handle queue messages
6 years ago
Andrii Shvaika
99d322d449
Refactoring of the rule engine
6 years ago
Andrii Shvaika
ce6ec88983
Refactoring of the websocket and subscription services
6 years ago
Andrii Shvaika
e102b55bc1
Thread-safety usage of Kafka Consumer
6 years ago
Andrii Shvaika
7203e7aa19
Distributed Mode fixes
6 years ago
Andrii Shvaika
94eb213716
Implementation
6 years ago
Andrii Shvaika
7de485f453
Kafka configuration
6 years ago
Andrii Shvaika
2a815058e7
Improvements and bugfix to QueueProviders
6 years ago
Andrii Shvaika
23c017567b
Implementation of Queue Interfaces
6 years ago
Andrii Shvaika
e50796d84e
Service Discovery improvements
6 years ago
Yevhen Bondarenko
dc6081d820
Created kafka and in-memory queue providers
* Created kafka and in-memory queue providers
* Added header requestTime
* refactored
6 years ago
Andrii Shvaika
c4c53bfbd8
Transport Implementation
6 years ago
Andrii Shvaika
fa9194c1c1
Core consumer service implementation
6 years ago
Andrii Shvaika
52814d2bfc
Refactoring of Transport Communication to Queues
6 years ago
Andrii Shvaika
6e31c0ab15
Refactoring of configuration properties
6 years ago
YevhenBondarenko
4ad4fe11da
created in memory queue
6 years ago
YevhenBondarenko
d68ef2333a
updated guava and protobuf versions
6 years ago
Andrii Shvaika
7b2bdeab23
Refactoring of Transport Interfaces
6 years ago
Andrii Shvaika
a39e8c3756
Queue Implementation
6 years ago
Andrii Shvaika
b7c652ab07
Refactoring of Queue Interfaces
6 years ago
Igor Kulikov
3e2a87135f
Prepare for merge with master
6 years ago
Igor Kulikov
850d6d948c
Update License header year to 2020
7 years ago
Igor Kulikov
1265a9a1e3
Revert "Update License header year to 2020"
This reverts commit 9b42397c4a .
7 years ago
Igor Kulikov
9b42397c4a
Update License header year to 2020
7 years ago
Andrew Shvayka
5fe40b70b3
No more protobuf in JS executor
7 years ago
Igor Kulikov
ecfcf7b879
Remove redundant logback.xml
7 years ago
Igor Kulikov
0d7bf40a97
Add clientId parameter to all Kafka producers.
7 years ago
Igor Kulikov
ced63c4e70
Update License Header year to 2019
7 years ago
Igor Kulikov
68c0cd6291
Improve kafka topics management. Improve black box tests.
8 years ago
Igor Kulikov
5fd600b8cc
Kafka request template exceptions handling.
8 years ago
Igor Kulikov
f6b00b35db
Improve docker compose. Improve TB shutdown logic.
8 years ago
Igor Kulikov
5f40dcacdb
Fix docker env files. Improve logging.
8 years ago
Andrew Shvayka
5d5100ef1b
Improved logging
8 years ago
Andrew Shvayka
b6ca497098
Rate Limiter for Kafka Consumer
8 years ago
Andrew Shvayka
6165b90839
Rate limitter for Kafka consumer
8 years ago
Andrew Shvayka
4255bb56a3
Implementation of Session Cache, TTL and few minor fixes
8 years ago
Andrew Shvayka
67431a044a
Refactoring of packages
8 years ago
Andrew Shvayka
2590f04ac0
Local Transport Service implementation
8 years ago