@@ -625,13 +625,13 @@ impl Builder {
625625 chan_handler : Arc :: clone ( & channel_manager) ,
626626 route_handler : Arc :: clone ( & p2p_gossip_sync)
627627 as Arc < dyn RoutingMessageHandler + Sync + Send > ,
628- onion_message_handler : onion_messenger,
628+ onion_message_handler : onion_messenger. clone ( ) ,
629629 } ,
630630 GossipSync :: Rapid ( _) => MessageHandler {
631631 chan_handler : Arc :: clone ( & channel_manager) ,
632632 route_handler : Arc :: new ( IgnoringMessageHandler { } )
633633 as Arc < dyn RoutingMessageHandler + Sync + Send > ,
634- onion_message_handler : onion_messenger,
634+ onion_message_handler : onion_messenger. clone ( ) ,
635635 } ,
636636 GossipSync :: None => {
637637 unreachable ! ( "We must always have a gossip sync!" ) ;
@@ -705,6 +705,7 @@ impl Builder {
705705 scorer,
706706 peer_store,
707707 payment_store,
708+ _onion_messenger : onion_messenger,
708709 } )
709710 }
710711}
@@ -731,6 +732,7 @@ pub struct Node<K: KVStore + Sync + Send + 'static> {
731732 scorer : Arc < Mutex < Scorer > > ,
732733 peer_store : Arc < PeerStore < K , Arc < FilesystemLogger > > > ,
733734 payment_store : Arc < PaymentStore < K , Arc < FilesystemLogger > > > ,
735+ _onion_messenger : Arc < OnionMessenger > ,
734736}
735737
736738impl < K : KVStore + Sync + Send + ' static > Node < K > {
0 commit comments