@@ -936,6 +936,9 @@ fn build_with_store_internal(
936936 100 ;
937937 }
938938
939+ let message_router =
940+ Arc :: new ( MessageRouter :: new ( Arc :: clone ( & network_graph) , Arc :: clone ( & keys_manager) ) ) ;
941+
939942 // Initialize the ChannelManager
940943 let channel_manager = {
941944 if let Ok ( res) = kv_store. read (
@@ -954,6 +957,7 @@ fn build_with_store_internal(
954957 Arc :: clone ( & chain_monitor) ,
955958 Arc :: clone ( & tx_broadcaster) ,
956959 Arc :: clone ( & router) ,
960+ Arc :: clone ( & message_router) ,
957961 Arc :: clone ( & logger) ,
958962 user_config,
959963 channel_monitor_references,
@@ -978,6 +982,7 @@ fn build_with_store_internal(
978982 Arc :: clone ( & chain_monitor) ,
979983 Arc :: clone ( & tx_broadcaster) ,
980984 Arc :: clone ( & router) ,
985+ Arc :: clone ( & message_router) ,
981986 Arc :: clone ( & logger) ,
982987 Arc :: clone ( & keys_manager) ,
983988 Arc :: clone ( & keys_manager) ,
@@ -1000,18 +1005,17 @@ fn build_with_store_internal(
10001005 } ) ?;
10011006 }
10021007
1003- let message_router = MessageRouter :: new ( Arc :: clone ( & network_graph) , Arc :: clone ( & keys_manager) ) ;
1004-
10051008 // Initialize the PeerManager
10061009 let onion_messenger: Arc < OnionMessenger > = Arc :: new ( OnionMessenger :: new (
10071010 Arc :: clone ( & keys_manager) ,
10081011 Arc :: clone ( & keys_manager) ,
10091012 Arc :: clone ( & logger) ,
10101013 Arc :: clone ( & channel_manager) ,
1011- Arc :: new ( message_router) ,
1014+ message_router,
10121015 Arc :: clone ( & channel_manager) ,
10131016 IgnoringMessageHandler { } ,
10141017 IgnoringMessageHandler { } ,
1018+ IgnoringMessageHandler { } ,
10151019 ) ) ;
10161020 let ephemeral_bytes: [ u8 ; 32 ] = keys_manager. get_secure_random_bytes ( ) ;
10171021
0 commit comments