diff options
Diffstat (limited to 'cloud/pkg/common/messagelayer/context.go')
| -rw-r--r-- | cloud/pkg/common/messagelayer/context.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/cloud/pkg/common/messagelayer/context.go b/cloud/pkg/common/messagelayer/context.go index 8a2e9d4bd..cf632345f 100644 --- a/cloud/pkg/common/messagelayer/context.go +++ b/cloud/pkg/common/messagelayer/context.go @@ -96,6 +96,14 @@ func DynamicControllerMessageLayer() MessageLayer { } } +func TaskManagerMessageLayer() MessageLayer { + return &ContextMessageLayer{ + SendModuleName: modules.CloudHubModuleName, + ReceiveModuleName: modules.TaskManagerModuleName, + ResponseModuleName: modules.CloudHubModuleName, + } +} + func NodeUpgradeJobControllerMessageLayer() MessageLayer { return &ContextMessageLayer{ SendModuleName: modules.CloudHubModuleName, |