diff options
Diffstat (limited to 'edge/pkg/edgehub/process.go')
| -rw-r--r-- | edge/pkg/edgehub/process.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/edge/pkg/edgehub/process.go b/edge/pkg/edgehub/process.go index 05499e3f6..bc08f02bb 100644 --- a/edge/pkg/edgehub/process.go +++ b/edge/pkg/edgehub/process.go @@ -73,6 +73,14 @@ func (*defaultHandler) Process(message *model.Message, clientHub clients.Adapter md = modules.BusGroup } + // TODO: just for a temporary fix. + // The code related to device twin message transmission will be reconstructed + // by using sendSync function instead of send function. + if group == messagepkg.TwinGroupName { + beehiveContext.SendToGroup(md, *message) + return nil + } + isResponse := isSyncResponse(message.GetParentID()) if isResponse { beehiveContext.SendResp(*message) |