 Jiyong Huang
|
dd43f71f27
fix(mqtt): sync mqtt connection state
|
преди 2 години |
 Jianxiang Ran
|
95af0afc5c
fix(fea): add docs for resourceId reference
|
преди 2 години |
|
Jianxiang Ran
|
72a6f29cc3
fix(fea): uniform get /release client api
|
преди 2 години |
|
ngjaying
|
47f65478eb
Connection exception management (#1379)
|
преди 2 години |
|
Jianxiang Ran
|
8701f5e39a
fix(source): handle mqtt subscription errors gracefully
|
преди 2 години |
|
Jianxiang Ran
|
4d251b6dee
fix(source): do not exit the rule when connecting to message broker fail
|
преди 2 години |
|
ngjaying
|
c26776ba5d
offline cache (#1304)
|
преди 2 години |
|
Jiyong Huang
|
cc088e4ee3
refactor(*): broadcast using non-blocking
|
преди 3 години |
|
Jianxiang Ran
|
c3fb72c94b
fix(edgex): fix subscription for same topics multiple times
|
преди 3 години |
 superxan
|
e2ecbd0861
fix(edgex): fix crash when using single channel for multiple topics subscription (#1214)
|
преди 3 години |
|
superxan
|
5268084a32
fix(rule): fix rule qos 1 and sink cache error (#1204)
|
преди 3 години |
|
Jianxiang Ran
|
805fdd97e9
refactor(connection): use map[string]interface{} to hold parameters
|
преди 3 години |
|
Jianxiang Ran
|
2bded566c2
refactor(connection): refactor mqtt/edgex connection share
|
преди 3 години |
|
Jianxiang Ran
|
9cfcdd6665
refactor(connection): refactor mqtt/edgex connection share
|
преди 3 години |
|
Jianxiang Ran
|
26d3694295
refactor(connection): refactor mqtt/edgex connection share
|
преди 3 години |
