@@ -71,7 +71,7 @@ async fn load_data_from_database(config: &Configuration, app_container: &Arc<App
7171async fn start_jobs ( config : & Configuration , app_container : & Arc < AppContainer > ) -> JobManager {
7272 let mut job_manager = JobManager :: new ( ) ;
7373
74- start_torrent_repository_event_listener ( config, app_container, & mut job_manager) ;
74+ start_swarm_coordination_registry_event_listener ( config, app_container, & mut job_manager) ;
7575 start_tracker_core_event_listener ( config, app_container, & mut job_manager) ;
7676 start_http_core_event_listener ( config, app_container, & mut job_manager) ;
7777 start_udp_core_event_listener ( config, app_container, & mut job_manager) ;
@@ -132,13 +132,13 @@ async fn load_torrent_metrics(config: &Configuration, app_container: &Arc<AppCon
132132 }
133133}
134134
135- fn start_torrent_repository_event_listener (
135+ fn start_swarm_coordination_registry_event_listener (
136136 config : & Configuration ,
137137 app_container : & Arc < AppContainer > ,
138138 job_manager : & mut JobManager ,
139139) {
140140 job_manager. push_opt (
141- "torrent_repository_event_listener " ,
141+ "swarm_coordination_registry_event_listener " ,
142142 jobs:: torrent_repository:: start_event_listener ( config, app_container) ,
143143 ) ;
144144}
0 commit comments