We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2735bb4 commit 2534a80Copy full SHA for 2534a80
1 file changed
internal/controller/eventbus/controller.go
@@ -360,6 +360,7 @@ func (ctrl *controller) deleteEventbus(ctx context.Context, id vanus.ID) error {
360
361
// TODO(wenfeng.wang) notify gateway to cut flow
362
delete(ctrl.eventbusMap, id)
363
+ ctrl.eventbusNamespaceMapping.Delete(GetMappingKey(bus.NamespaceID, bus.Name))
364
wg := sync.WaitGroup{}
365
366
for _, v := range bus.Eventlogs {
0 commit comments