diff options
| author | fisherxu <xufei40@huawei.com> | 2020-02-24 18:53:09 +0800 |
|---|---|---|
| committer | fisherxu <xufei40@huawei.com> | 2020-02-28 14:52:58 +0800 |
| commit | 23c65d7dbd00c376b8d4434c697e2613d6e1b8a0 (patch) | |
| tree | 1e026cf1c76cdddad7e098ab6f718205724349c0 | |
| parent | add device e2e test (diff) | |
| download | kubeedge-23c65d7dbd00c376b8d4434c697e2613d6e1b8a0.tar.gz | |
fix device update event can't send to edge
| -rw-r--r-- | cloud/pkg/cloudhub/channelq/channelq.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/cloud/pkg/cloudhub/channelq/channelq.go b/cloud/pkg/cloudhub/channelq/channelq.go index 6ca5ab1ba..9d1b1c3de 100644 --- a/cloud/pkg/cloudhub/channelq/channelq.go +++ b/cloud/pkg/cloudhub/channelq/channelq.go @@ -15,7 +15,6 @@ import ( beehiveModel "github.com/kubeedge/beehive/pkg/core/model" "github.com/kubeedge/kubeedge/cloud/pkg/cloudhub/common/model" hubconfig "github.com/kubeedge/kubeedge/cloud/pkg/cloudhub/config" - deviceconstants "github.com/kubeedge/kubeedge/cloud/pkg/devicecontroller/constants" edgeconst "github.com/kubeedge/kubeedge/cloud/pkg/edgecontroller/constants" edgemessagelayer "github.com/kubeedge/kubeedge/cloud/pkg/edgecontroller/messagelayer" "github.com/kubeedge/kubeedge/cloud/pkg/synccontroller" @@ -170,7 +169,7 @@ func isListResource(msg *beehiveModel.Message) bool { strings.Contains(msgResource, commonconst.ResourceTypeServiceList) || strings.Contains(msgResource, commonconst.ResourceTypeEndpointsList) || strings.Contains(msgResource, "membership") || - strings.Contains(msgResource, deviceconstants.ResourceTypeTwinEdgeUpdated) { + strings.Contains(msgResource, "twin/cloud_updated") { return true } |