import org.ldk.enums.*;
import org.ldk.util.*;
import java.util.Arrays;
+import javax.annotation.Nullable;
/**
* A trait to describe an object which can receive channel messages.
* 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.
*/
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);
}, MessageSendEventsProvider.new_impl(MessageSendEventsProvider_impl).bindings_instance);
return impl_holder.held;
}
+
+ /**
+ * Gets the underlying MessageSendEventsProvider.
+ */
+ public MessageSendEventsProvider get_message_send_events_provider() {
+ MessageSendEventsProvider res = new MessageSendEventsProvider(null, bindings.LDKChannelMessageHandler_get_MessageSendEventsProvider(this.ptr));
+ this.ptrs_to.add(res);
+ return res;
+ }
+
/**
* Handle an incoming open_channel message from the given peer.
*/
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.
*/