dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
24,109 Commits 106 Branches 71 Tags
Commit Graph

532 Commits

Author SHA1 Message Date
zbeacon
b6bd4247da Fix for PROD-1337 2022-01-21 13:13:08 +02:00
Andrew Shvayka
a3f3578b65
Merge pull request #5796 from desoliture1/gatewayFix 
[WIP][3.3.3] MQTT Gateway API - fix response data on attributes request
 2022-01-20 13:04:48 +02:00
desoliture
7b14fdaf5e add isMultipleAttributesRequest field in queue.proto in GetAttributeResponseMsg message 2022-01-17 18:59:39 +02:00
Igor Kulikov
da4c742872 Update license year to 2022 2022-01-17 14:07:46 +02:00
Andrew Shvayka
c15b4ceec3
Merge pull request #5843 from smatvienko-tb/device-actor-performance 
[3.3.3] Device actor session inactivity performance + heap workout
 2022-01-17 11:21:56 +02:00
Sergey Matvienko
1507ac69ab Revert "MqttTransportHandler refactored to not reference on InetSocketAddress instances to free some heap space. IPv4 are stored and logged as int." 
This reverts commit 0ef9d5753cd271fd7c8729567b5a2765943538d1.
 2022-01-14 11:50:36 +02:00
Sergey Matvienko
565b6284d2 Revert "MqttTransportHandler fixed test" 
This reverts commit ef53df75128a0502c5727d4229acd37cd79c1aaa.
 2022-01-14 11:50:31 +02:00
desoliture
35c30b7678 refactor GatewayDeviceSessionCtx and MqttAdaptors 
refactor GatewayDeviceSessionCtx to determine the value of multipleAttrKeysRequested before calling the JsonMqttAdaptor, add corresponding convertToGatewayPublish method to adaptors interface with multipleAttrKeysRequested parameter, refactor other adaptors to deal with new method
 2022-01-13 17:48:59 +02:00
Andrii Shvaika
236e6448be Fix unit tests logic 2022-01-13 16:59:29 +02:00
Andrii Shvaika
467085a827 IP rate limits for MQTT 2022-01-13 15:32:10 +02:00
Andrew Shvayka
d8097d2b76 MQTT Rate Limits Draft 2022-01-13 08:42:48 +02:00
Sergey Matvienko
b0a79e9fc3 static transport immutable proto SESSION_EVENT_MSG_OPEN, SESSION_EVENT_MSG_CLOSED, SESSION_CLOSE_NOTIFICATION_PROTO, SUBSCRIBE_TO_ATTRIBUTE_UPDATES_ASYNC_MSG, SUBSCRIBE_TO_RPC_ASYNC_MSG 2022-01-11 12:23:48 +02:00
Sergey Matvienko
ef53df7512 MqttTransportHandler fixed test 2022-01-10 18:41:53 +02:00
Sergey Matvienko
0ef9d5753c MqttTransportHandler refactored to not reference on InetSocketAddress instances to free some heap space. IPv4 are stored and logged as int. 2022-01-10 17:36:57 +02:00
desoliture
2f5648c400 refactoring 2021-12-29 17:24:55 +02:00
desoliture
b53746bda6 MQTT Gateway API attributes request fix 2021-12-29 16:31:15 +02:00
Andrew Shvayka
50f5e64195
Merge pull request #5788 from smatvienko-tb/mqtt-handler-log-reduce-severity 
[3.3.3] reduce MQTT info logs for connect/disconnect events
 2021-12-29 16:13:06 +02:00
Viacheslav Klimov
5d7b8f7c4e Fix invalid serialization of '=' to \u003d in JsonMqttAdaptor 2021-12-29 10:30:51 +02:00
Sergey Matvienko
35e8a53f8c mqtt: log.info replaced with log.debug for connect/disconnect event. It reduces log, CPU and disk overhead when few thousand devices in place. As alternative to debug mqtt - logback.xml adjusted 2021-12-28 19:46:32 +02:00
Igor Kulikov
7187ecfdb1 Version set to 3.3.3-SNAPSHOT 2021-11-24 12:24:27 +02:00
Andrii Shvaika
6d006d16c7 Improved rate limits message for MQTT session events 2021-11-24 10:38:45 +02:00
ShvaykaD
550af81f9c updated variable name in the TopicType enum: change Request to Response 2021-10-28 15:49:34 +03:00
ShvaykaD
09b75ac2e6 implementation updates after review 2021-10-27 12:57:53 +03:00
ShvaykaD
ac12eaecd8 Merge branch 'master' of github.com:ShvaykaD/thingsboard into feature/json-payload-for-v1-topics-in-proto-profile 2021-10-27 11:52:37 +03:00
ShvaykaD
bb8f92b122 fixed log typos in MqttTransportHandler 2021-10-27 11:31:59 +03:00
Igor Kulikov
362ccf9f31 Unified transport SSL credentials 2021-10-26 19:40:38 +03:00
ShvaykaD
0f71d0d8fc fix typos 2021-10-26 17:31:05 +03:00
ShvaykaD
75c1185d18 update logic after review 2021-10-26 17:25:27 +03:00
ShvaykaD
5f6b1d1ab3 MQTT backward compatibility adaptor: init commit 2021-10-26 12:59:05 +03:00
ShvaykaD
845d8247dd
[3.3.2] MQTT short topics support (#4967) 
* added mqtt short topics support

* remove volatile keyword from topic types parameters

* added new tests for mqtt short topics

* fix compilation error after merge

* improvements/typo-fixes after pull request review
 2021-10-08 15:20:38 +03:00
Andrii Shvaika
5bb6403407 Bug Fix after MQTT Transport connection statistics 2021-09-30 15:10:01 +03:00
Andrii Shvaika
d40bc48898 Ability to log number of active MQTT connections 2021-09-30 14:43:01 +03:00
Andrii Shvaika
c52c9a16ed Shutdown of the MQTT Transport in case of OOM error. 2021-09-29 12:16:39 +03:00
Igor Kulikov
049627db97 Version set to 3.3.2-SNAPSHOT 2021-09-06 18:55:10 +03:00
Igor Kulikov
7b6e8248d3
Merge branch 'master' into dependency-management-transitive-ce-3-3-1 2021-09-01 15:02:27 +03:00
Igor Kulikov
02b8b8b873
Merge branch 'master' into dependency-upgrade-test-scope 2021-09-01 14:57:02 +03:00
Sergey Matvienko
aefb7e4bb3 added netty-tcnative-boringssl-static.version 2.0.41.Final along with netty-all to support SSL 2021-09-01 13:55:45 +03:00
Andrii Shvaika
e5b988a297 Merge branch 'rpc-improvements' of https://github.com/YevhenBondarenko/thingsboard into develop/3.3.1 2021-08-19 18:04:32 +03:00
YevhenBondarenko
2a2441b248 used timeout from yml 2021-08-18 16:46:01 +03:00
YevhenBondarenko
5d6ec0dd0e refactoring 2021-08-18 10:48:04 +03:00
YevhenBondarenko
8513c99903 added sequence for the all RPC 2021-08-18 09:56:57 +03:00
YevhenBondarenko
8869dc0cb0 added new RPC statuses 2021-08-17 13:25:24 +03:00
Andrii Shvaika
3661647c3a Version set to 3.3.1-SNAPSHOT 2021-08-16 12:39:43 +03:00
Andrii Shvaika
2078c71d32 Added module cluster-api and used it in rule engine and other services 2021-08-06 17:33:52 +03:00
Sergey Matvienko
e223dda96f test scope: dependency upgrade a refactor for all POMs in project 2021-08-06 13:53:35 +03:00
Andrii Shvaika
daac250c2e Correct close and cleanup of the MQTT session context 2021-08-05 17:22:40 +03:00
Andrii Shvaika
9d651a7252 Fix reference count issue 2021-08-05 15:10:04 +03:00
Sergey Matvienko
33887ecb3b mqtt handler test improved 2021-08-04 19:02:16 +03:00
Sergey Matvienko
69a7779253 added MqttTransportHandlerTest 2021-08-04 19:02:16 +03:00
Sergey Matvienko
cbe51cee57 execute processMsgQueue on connected callback in separate thread because producer.send() will execute in Producer worker thread and can block messages producing 2021-08-04 19:02:16 +03:00