Skip to content

Commit 2b5de78

Browse files
committed
[Java] Build an OnionMessenger in CMC, connect ChanMan for offers
1 parent 2f0e19a commit 2b5de78

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/main/java/org/ldk/batteries/ChannelManagerConstructor.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ public static class InvalidSerializedDataException extends Exception {
5454
public PeerManager peer_manager = null;
5555
/**
5656
* A NioPeerHandler which manages a background thread to handle socket events and pass them to the peer_manager.
57-
*
58-
* This is `null` until `chain_sync_completed` is called.
57+
*
58+
* This is `null` until `chain_sync_completed` is called.
5959
*/
6060
public NioPeerHandler nio_peer_handler = null;
6161

@@ -288,8 +288,9 @@ public void chain_sync_completed(EventHandler event_handler, boolean use_p2p_gra
288288
routing_msg_handler = graph_msg_handler.as_RoutingMessageHandler();
289289
else
290290
routing_msg_handler = ignoring_handler.as_RoutingMessageHandler();
291+
OnionMessenger messenger = OnionMessenger.of(this.entropy_source, this.node_signer, this.logger, DefaultMessageRouter.of().as_MessageRouter(), channel_manager.as_OffersMessageHandler(), IgnoringMessageHandler.of().as_CustomOnionMessageHandler());
291292
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(),
292-
routing_msg_handler, ignoring_handler.as_OnionMessageHandler(),
293+
routing_msg_handler, messenger.as_OnionMessageHandler(),
293294
ignoring_handler.as_CustomMessageHandler(), (int)(System.currentTimeMillis() / 1000),
294295
this.entropy_source.get_secure_random_bytes(), logger, this.node_signer);
295296

0 commit comments

Comments
 (0)