Andrii Shvaika
|
37fd7f4988
|
Validation and Replacement of Queue names in the Device profile
|
5 years ago |
Volodymyr Babak
|
6f9ac66863
|
Refactoring: Introduced Edge License service. Remove web dependency from dao
|
5 years ago |
|
Volodymyr Babak
|
97e1a900f2
|
EdgeGrpcClient: added compression
|
5 years ago |
|
Volodymyr Babak
|
5007eccb26
|
Added logs for edge license check. Replaced Object class with JsonNode
|
5 years ago |
|
Andrii Shvaika
|
a51c00bd10
|
Session Activity reporting is isolated and supports short-lived sessions
|
5 years ago |
YevhenBondarenko
|
d49bee4b31
|
send next rpc after removing
|
5 years ago |
|
YevhenBondarenko
|
2a2441b248
|
used timeout from yml
|
5 years ago |
|
YevhenBondarenko
|
5d6ec0dd0e
|
refactoring
|
5 years ago |
|
YevhenBondarenko
|
8513c99903
|
added sequence for the all RPC
|
5 years ago |
|
YevhenBondarenko
|
8869dc0cb0
|
added new RPC statuses
|
5 years ago |
Vladyslav_Prykhodko
|
8c0c6bdcff
|
Change json property order in model WidgetTypeDetails
|
5 years ago |
|
YevhenBondarenko
|
6436c8a26c
|
Implemented rpc sending sequence
|
5 years ago |
|
Andrii Shvaika
|
3661647c3a
|
Version set to 3.3.1-SNAPSHOT
|
5 years ago |
Sergey Matvienko
|
6d20ca441e
|
Merge TS fix using cherry-pick
|
5 years ago |
|
Sergey Matvienko
|
ea217d2a4e
|
cache: Transaction aware cache to synchronize cache put/evict operations with ongoing Spring-managed transactions.
|
5 years ago |
|
Andrii Shvaika
|
8a2dc7583b
|
Fix cluster mode for DefaultOtaPackageStateService
|
5 years ago |
|
Volodymyr Babak
|
3bf48f0f5e
|
Do not push entity updated to edge on device creation from edge
|
5 years ago |
Viacheslav Klimov
|
b0c6ce9f98
|
Fix circular reference for CoapClientContext and CoapTransportContext
|
5 years ago |
|
YevhenBondarenko
|
d44adcfe75
|
added removing rpc request from pending map after rpc deleting
|
5 years ago |
|
Andrii Shvaika
|
2078c71d32
|
Added module cluster-api and used it in rule engine and other services
|
5 years ago |
|
Andrii Shvaika
|
daac250c2e
|
Correct close and cleanup of the MQTT session context
|
5 years ago |
ShvaykaD
|
60e15ece5a
|
replaced protobuf-wrappers usage to optional keyword
|
5 years ago |
|
Sergey Matvienko
|
1d7e0b9851
|
queue.kafka.max.request.size:1048576 default to tolerate inconsistent or outdated yml
|
5 years ago |
|
Sergey Matvienko
|
a5ff95b0f4
|
Kafka producer added TB_KAFKA_MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION and TB_KAFKA_MAX_REQUEST_SIZE
|
5 years ago |
|
YevhenBondarenko
|
373f2f9f0e
|
added additionalInfo to the rpc
|
5 years ago |
|
Volodymyr Babak
|
2558b2ecda
|
Device credential value can be null
|
5 years ago |
|
Andrii Shvaika
|
9d651a7252
|
Fix reference count issue
|
5 years ago |
|
Sergey Matvienko
|
33887ecb3b
|
mqtt handler test improved
|
5 years ago |
|
Sergey Matvienko
|
69a7779253
|
added MqttTransportHandlerTest
|
5 years ago |
|
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
|
5 years ago |
|
Sergey Matvienko
|
607fd7a74f
|
mqtt transport handler refactored for test
|
5 years ago |
|
Sergey Matvienko
|
43fc44f071
|
fixed >= with > for MessageQueueSizePerDeviceLimit according to test results
|
5 years ago |
|
Sergey Matvienko
|
7dfed3e14a
|
removed msg-processor-on-device-connect executor. will use transportCallbackExecutor instead
|
5 years ago |
|
Sergey Matvienko
|
efe123d96b
|
transport.mqtt.msg_queue_size_per_device_limit:100 in code
|
5 years ago |
|
Sergey Matvienko
|
1f1f7e3456
|
DeviceAwareSessionContext refactored: setDeviceInfo splitted into setDeviceInfo and setConnected to able to set connected status on callback after device info already set.
|
5 years ago |
|
Sergey Matvienko
|
40bcd2fa8a
|
mqtt transport refactored msqProcessorExecutor lifecycle
|
5 years ago |
|
Sergey Matvienko
|
712ccd4c26
|
mqtt transport renamed thread pool msqProcessorExecutor
|
5 years ago |
|
Sergey Matvienko
|
5741e34c62
|
mqtt transport accumulate msg before device isConnected
|
5 years ago |
|
Volodymyr Babak
|
5557406f07
|
Added alarm id for future needs
|
5 years ago |
|
YevhenBondarenko
|
ee74bbed21
|
fixed race condition during unreq and updating lwm2m client
|
5 years ago |
nickAS21
|
4457b5a11a
|
Lwm2m: fix bug Bootstrap + Tests NoSec - ok
|
5 years ago |
|
YevhenBondarenko
|
309715641f
|
fixed race condition during unreq
|
5 years ago |
|
Sergey Matvienko
|
b8cecbeefd
|
close channel if processPostTelemetryMsg exception (Failed to convert telemetry)
|
5 years ago |
|
Sergey Matvienko
|
e3303f1b64
|
this.deviceCreationLockMap = createWeakMap();
|
5 years ago |
|
Sergey Matvienko
|
6e559994ca
|
GatewaySessionHandlerTest license header fixed for CE
|
5 years ago |
|
Sergey Matvienko
|
2cad1f9912
|
gateway session test added for a weak map with awaitility
|
5 years ago |
|
Sergey Matvienko
|
89e3ba253c
|
gateway session - weak map for locks (auto cleanup), getDeviceCreationFuture refactored using concurrent putIfAbsent
|
5 years ago |
|
Sergey Matvienko
|
e61d433082
|
mqtt transport close channel on processing exception for handleGatewayPublishMsg method
|
5 years ago |
|
Sergey Matvienko
|
2a4a9187d1
|
kafka producer - call callback.onFailure in case of producer.send exception (like InterruptedException when buffer.memory and max.block.ms reached)
|
5 years ago |
|
Volodymyr Babak
|
e05e681bd9
|
Properly hanlde null values in proto classes
|
5 years ago |
