UDPMulticastChannelFactory.java 文件源码

private void doJoin(final ChannelFuture bindFuture, final DatagramChannel channel, final NetworkInterface interf,
        final InetSocketAddress address, final ChannelPromise promise) {
    channel.eventLoop().execute(new Runnable() {
        @Override
        public void run() {
            LOGGER.entry(bindFuture, channel, interf, address, promise);
            if (bindFuture.isSuccess()) {
                LOGGER.debug("joining group {} with {} using {} and promise {}", address, interf, channel, promise);
                channel.joinGroup(address, interf, promise);
            } else {
                promise.setFailure(bindFuture.cause());
            }
            LOGGER.exit();
        }
    });
}