X-Git-Url: http://git.bitcoin.ninja/index.cgi?p=ldk-java;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fldk%2Fbatteries%2FChannelManagerConstructor.java;h=bfa33991c13a31402731543d4dcf860d2d4b469d;hp=3f90f1c61bebe8285df1a985b59babd9319b8708;hb=2b5de78f9d131e8ee25bc9abf869aec5328b9ef3;hpb=2f0e19ab23f28c5c1bc11dc6bff24e156da3ec01 diff --git a/src/main/java/org/ldk/batteries/ChannelManagerConstructor.java b/src/main/java/org/ldk/batteries/ChannelManagerConstructor.java index 3f90f1c6..bfa33991 100644 --- a/src/main/java/org/ldk/batteries/ChannelManagerConstructor.java +++ b/src/main/java/org/ldk/batteries/ChannelManagerConstructor.java @@ -54,8 +54,8 @@ public class ChannelManagerConstructor { public PeerManager peer_manager = null; /** * A NioPeerHandler which manages a background thread to handle socket events and pass them to the peer_manager. - * - * This is `null` until `chain_sync_completed` is called. + * + * This is `null` until `chain_sync_completed` is called. */ public NioPeerHandler nio_peer_handler = null; @@ -288,8 +288,9 @@ public class ChannelManagerConstructor { routing_msg_handler = graph_msg_handler.as_RoutingMessageHandler(); else routing_msg_handler = ignoring_handler.as_RoutingMessageHandler(); + OnionMessenger messenger = OnionMessenger.of(this.entropy_source, this.node_signer, this.logger, DefaultMessageRouter.of().as_MessageRouter(), channel_manager.as_OffersMessageHandler(), IgnoringMessageHandler.of().as_CustomOnionMessageHandler()); this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(), - routing_msg_handler, ignoring_handler.as_OnionMessageHandler(), + routing_msg_handler, messenger.as_OnionMessageHandler(), ignoring_handler.as_CustomMessageHandler(), (int)(System.currentTimeMillis() / 1000), this.entropy_source.get_secure_random_bytes(), logger, this.node_signer);