diff options
| author | hellocn9 <zhangyancn9@126.com> | 2023-05-19 10:11:11 +0800 |
|---|---|---|
| committer | hellocn9 <zhangyancn9@126.com> | 2023-05-19 10:11:11 +0800 |
| commit | 7eb7c98abf7141af79b254214a7b7ab0c8251eb8 (patch) | |
| tree | 210b2077139ad0c66ec00f2cfbd201cc1719a8fb /edge | |
| parent | Merge pull request #4712 from Shelley-BaoYue/goprocess (diff) | |
| download | kubeedge-7eb7c98abf7141af79b254214a7b7ab0c8251eb8.tar.gz | |
fix the problem of not being able to create multiple servicebus to rest's rules
Signed-off-by: hellocn9 <zhangyancn9@126.com>
Diffstat (limited to 'edge')
| -rw-r--r-- | edge/pkg/servicebus/servicebus.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/edge/pkg/servicebus/servicebus.go b/edge/pkg/servicebus/servicebus.go index 1f7e06e02..cb6dd74d7 100644 --- a/edge/pkg/servicebus/servicebus.go +++ b/edge/pkg/servicebus/servicebus.go @@ -124,8 +124,8 @@ func processMessage(msg *beehiveModel.Message) { resource := msg.GetResource() switch msg.GetOperation() { case "start": + dao.InsertUrls(resource) if atomic.CompareAndSwapInt32(&inited, 0, 1) { - dao.InsertUrls(resource) go server(c) } case "stop": |