@@ -765,18 +765,6 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
765765
766766 let runtime = tokio:: runtime:: Builder :: new_multi_thread ( ) . enable_all ( ) . build ( ) . unwrap ( ) ;
767767
768- let event_handler = Arc :: new ( EventHandler :: new (
769- Arc :: clone ( & self . wallet ) ,
770- Arc :: clone ( & self . event_queue ) ,
771- Arc :: clone ( & self . channel_manager ) ,
772- Arc :: clone ( & self . network_graph ) ,
773- Arc :: clone ( & self . keys_manager ) ,
774- Arc :: clone ( & self . payment_store ) ,
775- Arc :: clone ( & self . runtime ) ,
776- Arc :: clone ( & self . logger ) ,
777- Arc :: clone ( & self . config ) ,
778- ) ) ;
779-
780768 // Setup wallet sync
781769 let wallet = Arc :: clone ( & self . wallet ) ;
782770 let tx_sync = Arc :: clone ( & self . tx_sync ) ;
@@ -1023,6 +1011,18 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
10231011 }
10241012 } ) ;
10251013
1014+ let event_handler = Arc :: new ( EventHandler :: new (
1015+ Arc :: clone ( & self . wallet ) ,
1016+ Arc :: clone ( & self . event_queue ) ,
1017+ Arc :: clone ( & self . channel_manager ) ,
1018+ Arc :: clone ( & self . network_graph ) ,
1019+ Arc :: clone ( & self . keys_manager ) ,
1020+ Arc :: clone ( & self . payment_store ) ,
1021+ Arc :: clone ( & self . runtime ) ,
1022+ Arc :: clone ( & self . logger ) ,
1023+ Arc :: clone ( & self . config ) ,
1024+ ) ) ;
1025+
10261026 // Setup background processing
10271027 let background_persister = Arc :: clone ( & self . kv_store ) ;
10281028 let background_event_handler = Arc :: clone ( & event_handler) ;
0 commit comments