Package org.xnio.channels

Examples of org.xnio.channels.MulticastMessageChannel


        if (group == null || linuxLike) {
            bindAddress = new InetSocketAddress(config.getAdvertisePort());
        } else {
            bindAddress = new InetSocketAddress(group, config.getAdvertisePort());
        }
        final MulticastMessageChannel channel = worker.createUdpServer(bindAddress, new ChannelListener<MulticastMessageChannel>() {
            @Override
            public void handleEvent(MulticastMessageChannel channel) {
                channel.resumeWrites();
            }
        }, OptionMap.EMPTY);
        final MCMPAdvertiseTask task = new MCMPAdvertiseTask(container, config, channel);
        channel.getIoThread().executeAtInterval(task, config.getAdvertiseFrequency(), TimeUnit.MILLISECONDS);
    }
View Full Code Here

TOP

Related Classes of org.xnio.channels.MulticastMessageChannel

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.