From 9eebd710827a35bee33dd0c2eb1f0d38e78b7991 Mon Sep 17 00:00:00 2001 From: mxsm Date: Wed, 8 Jan 2025 07:34:15 +0000 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2170]=F0=9F=90=9BFix=20BatchUnregistr?= =?UTF-8?q?ationService=20not=20started=20when=20Name=20server=20start?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-namesrv/src/route/batch_unregistration_service.rs | 2 ++ rocketmq-namesrv/src/route/route_info_manager.rs | 1 + 2 files changed, 3 insertions(+) diff --git a/rocketmq-namesrv/src/route/batch_unregistration_service.rs b/rocketmq-namesrv/src/route/batch_unregistration_service.rs index 7cce91be..34f9c719 100644 --- a/rocketmq-namesrv/src/route/batch_unregistration_service.rs +++ b/rocketmq-namesrv/src/route/batch_unregistration_service.rs @@ -16,6 +16,7 @@ */ use rocketmq_remoting::protocol::header::namesrv::broker_request::UnRegisterBrokerRequestHeader; use rocketmq_rust::ArcMut; +use tracing::info; use tracing::warn; use crate::bootstrap::NameServerRuntimeInner; @@ -53,6 +54,7 @@ impl BatchUnregistrationService { let mut rx = self.rx.take().expect("rx is None"); let limit = 10; tokio::spawn(async move { + info!(">>>>>>>>BatchUnregistrationService started<<<<<<<<<<<<<<<<<<<"); loop { let mut unregistration_requests = Vec::with_capacity(limit); tokio::select! { diff --git a/rocketmq-namesrv/src/route/route_info_manager.rs b/rocketmq-namesrv/src/route/route_info_manager.rs index 41957824..db1b5be6 100644 --- a/rocketmq-namesrv/src/route/route_info_manager.rs +++ b/rocketmq-namesrv/src/route/route_info_manager.rs @@ -1207,6 +1207,7 @@ impl RouteInfoManager { //! start client connection disconnected listener pub fn start(&self, receiver: broadcast::Receiver) { let mut inner = self.name_server_runtime_inner.clone(); + self.un_register_service.mut_from_ref().start(); let mut receiver = receiver; tokio::spawn(async move { while let Ok(socket_addr) = receiver.recv().await {