a38ee80e09
Refactoring of device creation using gateway
6 years ago
79b4411c69
Synchronization of device connect processing in gateways
6 years ago
eb3cc332d1
Fix gateway/device last activity time checks
6 years ago
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.
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
a779839081
Fixed transport
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
b1f87206f3
Minor improvements
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
e991c0ef23
No more Synchronization nodes
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
5b8ce2fb69
Move AlarmId To Id Package
6 years ago
7869fb5ef4
added to tenant fields isolatedTbCore and isolatedTbRuleEngine ( #2611 )
Co-authored-by: Andrew Shvayka <ashvayka@thingsboard.io>
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
11479935c2
SQL TTL Implemenation
* init commit
* improvements for ttl-functions
* added drop partitions by ttl function
* add load ttl function to upgrade script
* fix typo
* add IF NOT EXISTS for json_v in timescale upgrade
* changed logic for removing customer records from ts_kv
* improvements in upgrade scenario
* improvements
* added intial delay for TTL task execution
6 years ago
45bd764e6f
Azure ServiceBus queue
* created event hubs queue
* created servicebus queue
* refactored
* refactored
6 years ago
ff3fd89ace
Added ability to process tellNext messages from Queue
6 years ago
638ca0e1d1
Refactoring to multiple queues for rule engine
6 years ago
d94cb9ca47
Added correct ts on alarm clear and ack actions ( #2550 )
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
07bdcac0fe
Refactoring of Rule Engine API
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
Andrii Shvaika
bdrlamb
YevhenBondarenko
Yevhen Bondarenko
hamza.slama
ShvaykaD
VoBa