X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fldk%2Fstructs%2FChannelMessageHandler.java;fp=src%2Fmain%2Fjava%2Forg%2Fldk%2Fstructs%2FChannelMessageHandler.java;h=c5bb627289593e065d271538cb4d413451edf62d;hb=f8c25e52ce878136043ddc4dbfac6c6640f1d4f6;hp=5eaedc1652e4e16ed601ee33e25a5e8c177c1d45;hpb=bbc02b4a3cfdb5f32cdd650fdcd4dc4e55ca1517;p=ldk-java diff --git a/src/main/java/org/ldk/structs/ChannelMessageHandler.java b/src/main/java/org/ldk/structs/ChannelMessageHandler.java index 5eaedc16..c5bb6272 100644 --- a/src/main/java/org/ldk/structs/ChannelMessageHandler.java +++ b/src/main/java/org/ldk/structs/ChannelMessageHandler.java @@ -102,6 +102,10 @@ public class ChannelMessageHandler extends CommonBase { * Handle an incoming channel_reestablish message from the given peer. */ void handle_channel_reestablish(byte[] their_node_id, ChannelReestablish msg); + /** + * Handle an incoming channel update from the given peer. + */ + void handle_channel_update(byte[] their_node_id, ChannelUpdate msg); /** * Handle an incoming error message from the given peer. */ @@ -187,6 +191,10 @@ public class ChannelMessageHandler extends CommonBase { ChannelReestablish msg_hu_conv = new ChannelReestablish(null, msg); arg.handle_channel_reestablish(their_node_id, msg_hu_conv); } + @Override public void handle_channel_update(byte[] their_node_id, long msg) { + ChannelUpdate msg_hu_conv = new ChannelUpdate(null, msg); + arg.handle_channel_update(their_node_id, msg_hu_conv); + } @Override public void handle_error(byte[] their_node_id, long msg) { ErrorMessage msg_hu_conv = new ErrorMessage(null, msg); arg.handle_error(their_node_id, msg_hu_conv); @@ -343,6 +351,14 @@ public class ChannelMessageHandler extends CommonBase { this.ptrs_to.add(msg); } + /** + * Handle an incoming channel update from the given peer. + */ + public void handle_channel_update(byte[] their_node_id, ChannelUpdate msg) { + bindings.ChannelMessageHandler_handle_channel_update(this.ptr, their_node_id, msg == null ? 0 : msg.ptr & ~1); + this.ptrs_to.add(msg); + } + /** * Handle an incoming error message from the given peer. */