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
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
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
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
