desoliture
7b14fdaf5e
add isMultipleAttributesRequest field in queue.proto in GetAttributeResponseMsg message
2022-01-17 18:59:39 +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
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
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
Sergey Matvienko
607fd7a74f
mqtt transport handler refactored for test
2021-08-04 19:02:16 +03:00
Sergey Matvienko
43fc44f071
fixed >= with > for MessageQueueSizePerDeviceLimit according to test results
2021-08-04 19:02:16 +03:00
Sergey Matvienko
7dfed3e14a
removed msg-processor-on-device-connect executor. will use transportCallbackExecutor instead
2021-08-04 19:02:16 +03:00
Sergey Matvienko
efe123d96b
transport.mqtt.msg_queue_size_per_device_limit:100 in code
2021-08-04 19:02:16 +03:00
Sergey Matvienko
1f1f7e3456
DeviceAwareSessionContext refactored: setDeviceInfo splitted into setDeviceInfo and setConnected to able to set connected status on callback after device info already set.
2021-08-04 19:02:16 +03:00
Sergey Matvienko
40bcd2fa8a
mqtt transport refactored msqProcessorExecutor lifecycle
2021-08-04 19:02:16 +03:00
Sergey Matvienko
712ccd4c26
mqtt transport renamed thread pool msqProcessorExecutor
2021-08-04 19:02:16 +03:00
Sergey Matvienko
5741e34c62
mqtt transport accumulate msg before device isConnected
2021-08-04 19:02:16 +03:00
Sergey Matvienko
b8cecbeefd
close channel if processPostTelemetryMsg exception (Failed to convert telemetry)
2021-08-02 17:45:22 +03:00
Sergey Matvienko
e3303f1b64
this.deviceCreationLockMap = createWeakMap();
2021-08-02 17:45:22 +03:00
Sergey Matvienko
6e559994ca
GatewaySessionHandlerTest license header fixed for CE
2021-08-02 17:45:22 +03:00
Sergey Matvienko
2cad1f9912
gateway session test added for a weak map with awaitility
2021-08-02 17:45:22 +03:00
Sergey Matvienko
89e3ba253c
gateway session - weak map for locks (auto cleanup), getDeviceCreationFuture refactored using concurrent putIfAbsent
2021-08-02 17:45:22 +03:00
Sergey Matvienko
e61d433082
mqtt transport close channel on processing exception for handleGatewayPublishMsg method
2021-08-02 17:43:13 +03:00
Andrii Shvaika
f932a90b00
Improvements to Persistent RPC call delivery confirmation
2021-07-26 15:57:27 +03:00
