append to subscribers (#2640)

* append to subscribers * Update rpc_router.go error correction log
micro · Nov 26, 2023 · ca6190f · ca6190f
1 parent 674b982
commit ca6190f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/server/rpc_events.go b/server/rpc_events.go
@@ -137,6 +137,7 @@ func (s *rpcServer) reSubscribe(config Options) error {
 		}
 
 		s.subscribers[sb] = []broker.Subscriber{sub}
+		s.router.Subscribe(sb)
 	}
 
 	return nil

diff --git a/server/rpc_router.go b/server/rpc_router.go
@@ -549,6 +549,7 @@ func (router *router) ProcessMessage(ctx context.Context, msg Message) (err erro
 	subs, ok := router.subscribers[msg.Topic()]
 	router.su.RUnlock()
 	if !ok {
+		log.Warnf("Subscriber not found for topic %s", msg.Topic())
 		return nil
 	}
-Original file line number
+Diff line change
@@ Expand Up / @@ -137,6 +137,7 @@ func (s *rpcServer) reSubscribe(config Options) error { @@
     		}
     		s.subscribers[sb] = []broker.Subscriber{sub}
+    		s.router.Subscribe(sb)
     	}
     	return nil
@@ Expand Down @@