jchannelfactorydemo.java

来自「JGRoups源码」· Java 代码 · 共 44 行

package org.jgroups.tests;

import org.jgroups.Channel;
import org.jgroups.JChannelFactory;
import org.jgroups.jmx.JmxConfigurator;
import org.jgroups.util.Util;

import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import java.util.ArrayList;

/**
 * @author Bela Ban
 * @version $Id$
 */
public class JChannelFactoryDemo {
    JChannelFactory factory;
    MBeanServer server;

    public static void main(String[] args) throws Exception {
        new JChannelFactoryDemo().start();
    }

    private void start() throws Exception {
        server=Util.getMBeanServer();
        if(server == null) {
            throw new Exception("No MBeanServer found; JChannelFactory needs to be run with an MBeanServer present, " +
                    "inside JDK 5, or with ExposeChannel set to false");
        }
        factory=new JChannelFactory();
        factory.setExposeChannels(true);
        factory.setExposeProtocols(true);
        factory.setDomain("jgroups.mux");
        factory.setMultiplexerConfig("stacks.xml");
        factory.create();
        Channel ch=factory.createMultiplexerChannel("udp", "bla");
        JmxConfigurator.registerChannelFactory(factory, server, "jgroups.mux:name=Multiplexer");

        while(true) {
            Util.sleep(5000);
        }
    }
}