1. 包列表
  2. 类列表
  3. org.apache.catalina.tribes.ManagedChannel

Java 类org.apache.catalina.tribes.ManagedChannel 实例源码

项目：tomcat7    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：tomcat7    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：tomcat7    文件：TestTcpFailureDetector.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    channel1.getMembershipService().setPayload("Channel-1".getBytes("ASCII"));
    channel2.getMembershipService().setPayload("Channel-2".getBytes("ASCII"));
    mbrlist1 = new TestMbrListener("Channel-1");
    mbrlist2 = new TestMbrListener("Channel-2");
    tcpFailureDetector1 = new TcpFailureDetector();
    tcpFailureDetector2 = new TcpFailureDetector();
    channel1.addInterceptor(tcpFailureDetector1);
    channel2.addInterceptor(tcpFailureDetector2);
    channel1.addMembershipListener(mbrlist1);
    channel2.addMembershipListener(mbrlist2);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
}
项目：tomcat7    文件：TestMulticastPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：tomcat7    文件：TestUdpPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.73-with-comment    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：apache-tomcat-7.0.73-with-comment    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestTcpFailureDetector.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    channel1.getMembershipService().setPayload("Channel-1".getBytes("ASCII"));
    channel2.getMembershipService().setPayload("Channel-2".getBytes("ASCII"));
    mbrlist1 = new TestMbrListener("Channel-1");
    mbrlist2 = new TestMbrListener("Channel-2");
    tcpFailureDetector1 = new TcpFailureDetector();
    tcpFailureDetector2 = new TcpFailureDetector();
    channel1.addInterceptor(tcpFailureDetector1);
    channel2.addInterceptor(tcpFailureDetector2);
    channel1.addMembershipListener(mbrlist1);
    channel2.addMembershipListener(mbrlist2);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestMulticastPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestUdpPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：class-guard    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：class-guard    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：class-guard    文件：TestTcpFailureDetector.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    channel1.getMembershipService().setPayload("Channel-1".getBytes("ASCII"));
    channel2.getMembershipService().setPayload("Channel-2".getBytes("ASCII"));
    mbrlist1 = new TestMbrListener("Channel-1");
    mbrlist2 = new TestMbrListener("Channel-2");
    tcpFailureDetector1 = new TcpFailureDetector();
    tcpFailureDetector2 = new TcpFailureDetector();
    channel1.addInterceptor(tcpFailureDetector1);
    channel2.addInterceptor(tcpFailureDetector2);
    channel1.addMembershipListener(mbrlist1);
    channel2.addMembershipListener(mbrlist2);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
}
项目：class-guard    文件：TestMulticastPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：class-guard    文件：TestUdpPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：apache-tomcat-7.0.57    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：apache-tomcat-7.0.57    文件：TestTcpFailureDetector.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    channel1.getMembershipService().setPayload("Channel-1".getBytes("ASCII"));
    channel2.getMembershipService().setPayload("Channel-2".getBytes("ASCII"));
    mbrlist1 = new TestMbrListener("Channel-1");
    mbrlist2 = new TestMbrListener("Channel-2");
    tcpFailureDetector1 = new TcpFailureDetector();
    tcpFailureDetector2 = new TcpFailureDetector();
    channel1.addInterceptor(tcpFailureDetector1);
    channel2.addInterceptor(tcpFailureDetector2);
    channel1.addMembershipListener(mbrlist1);
    channel2.addMembershipListener(mbrlist2);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
}
项目：apache-tomcat-7.0.57    文件：TestMulticastPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：TestUdpPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：apache-tomcat-7.0.57    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：apache-tomcat-7.0.57    文件：TestTcpFailureDetector.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    channel1.getMembershipService().setPayload("Channel-1".getBytes("ASCII"));
    channel2.getMembershipService().setPayload("Channel-2".getBytes("ASCII"));
    mbrlist1 = new TestMbrListener("Channel-1");
    mbrlist2 = new TestMbrListener("Channel-2");
    tcpFailureDetector1 = new TcpFailureDetector();
    tcpFailureDetector2 = new TcpFailureDetector();
    channel1.addInterceptor(tcpFailureDetector1);
    channel2.addInterceptor(tcpFailureDetector2);
    channel1.addMembershipListener(mbrlist1);
    channel2.addMembershipListener(mbrlist2);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
}
项目：apache-tomcat-7.0.57    文件：TestMulticastPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：TestUdpPackages.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    ThroughputInterceptor tint = new ThroughputInterceptor();
    tint.setInterval(500);
    ThroughputInterceptor tint2 = new ThroughputInterceptor();
    tint2.setInterval(500);
    //channel1.addInterceptor(tint);
    channel2.addInterceptor(tint2);
    listener1 = new Listener();
    ReceiverBase rb1 = (ReceiverBase)channel1.getChannelReceiver();
    ReceiverBase rb2 = (ReceiverBase)channel2.getChannelReceiver();
    rb1.setUdpPort(50000);
    rb2.setUdpPort(50000);
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：wso2-axis2    文件：WkaBasedMembershipScheme.java    
public WkaBasedMembershipScheme(ManagedChannel channel,
                                OperationMode mode,
                                List<MembershipManager> applicationDomainMembershipManagers,
                                MembershipManager primaryMembershipManager,
                                Map<String, Parameter> parameters,
                                byte[] domain,
                                List<Member> members,
                                boolean atmostOnceMessageSemantics,
                                boolean preserverMsgOrder) {
    this.channel = channel;
    this.mode = mode;
    this.applicationDomainMembershipManagers = applicationDomainMembershipManagers;
    this.primaryMembershipManager = primaryMembershipManager;
    this.parameters = parameters;
    this.localDomain = domain;
    this.members = members;
    this.atmostOnceMessageSemantics = atmostOnceMessageSemantics;
    this.preserverMsgOrder = preserverMsgOrder;
    if(mode instanceof ClusterManagementMode){
        ((ClusterManagementMode) mode).setWkaBasedMembershipScheme(this);
    }
}
项目：WBSAirback    文件：MembersWithProperties.java    
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    if (args.length==0) usage();
    main = Thread.currentThread();
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    Properties props = new Properties();
    props.setProperty("mydomainkey","mydomainvalue");
    props.setProperty("someotherkey", Arrays.toString(UUIDGenerator.randomUUID(true)));
    new MembersWithProperties(channel, props);
    channel.start(Channel.DEFAULT);
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    try {
        Thread.sleep(Long.MAX_VALUE);
    }catch(InterruptedException ix) {
        Thread.sleep(5000);//allow everything to shutdown
    }
}
项目：WBSAirback    文件：MapDemo.java    
/**
 * Main method
 * @param args
 * @throws Exception
 */
@SuppressWarnings("unused")
public static void main(String[] args) throws Exception {
    long start = System.currentTimeMillis();
    //create a channel object
    ManagedChannel channel = (ManagedChannel) ChannelCreator.createChannel(args);
    //define a map name, unless one is defined as a paramters
    String mapName = "MapDemo";
    if ( args.length > 0 && (!args[args.length-1].startsWith("-"))) {
        mapName = args[args.length-1];
    }
    //start the channel
    channel.start(Channel.DEFAULT);
    //listen for shutdown
    Runtime.getRuntime().addShutdownHook(new Shutdown(channel));
    //create a map demo object
    new MapDemo(channel,mapName);

    //put the main thread to sleep until we are done
    System.out.println("System test complete, time to start="+(System.currentTimeMillis()-start)+" ms. Sleeping to let threads finish.");
    Thread.sleep(60 * 1000 * 60);
}
项目：tomcat7    文件：LoadTest.java    
public LoadTest(ManagedChannel channel,
                boolean send,
                int msgCount,
                boolean debug,
                long pause,
                int stats,
                boolean breakOnEx) {
    this.channel = channel;
    this.send = send;
    this.msgCount = msgCount;
    this.debug = debug;
    this.pause = pause;
    this.statsInterval = stats;
    this.breakonChannelException = breakOnEx;
}
项目：tomcat7    文件：TestDataIntegrity.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：tomcat7    文件：TestRemoteProcessException.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.73-with-comment    文件：LoadTest.java    
public LoadTest(ManagedChannel channel,
                boolean send,
                int msgCount,
                boolean debug,
                long pause,
                int stats,
                boolean breakOnEx) {
    this.channel = channel;
    this.send = send;
    this.msgCount = msgCount;
    this.debug = debug;
    this.pause = pause;
    this.statsInterval = stats;
    this.breakonChannelException = breakOnEx;
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestDataIntegrity.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestRemoteProcessException.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：class-guard    文件：LoadTest.java    
public LoadTest(ManagedChannel channel,
                boolean send,
                int msgCount,
                boolean debug,
                long pause,
                int stats,
                boolean breakOnEx) {
    this.channel = channel;
    this.send = send;
    this.msgCount = msgCount;
    this.debug = debug;
    this.pause = pause;
    this.statsInterval = stats;
    this.breakonChannelException = breakOnEx;
}
项目：class-guard    文件：TestDataIntegrity.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：class-guard    文件：TestRemoteProcessException.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：LoadTest.java    
public LoadTest(ManagedChannel channel,
                boolean send,
                int msgCount,
                boolean debug,
                long pause,
                int stats,
                boolean breakOnEx) {
    this.channel = channel;
    this.send = send;
    this.msgCount = msgCount;
    this.debug = debug;
    this.pause = pause;
    this.statsInterval = stats;
    this.breakonChannelException = breakOnEx;
}
项目：apache-tomcat-7.0.57    文件：TestDataIntegrity.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel1.addInterceptor(new MessageDispatch15Interceptor());
    channel2 = new GroupChannel();
    channel2.addInterceptor(new MessageDispatch15Interceptor());
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}
项目：apache-tomcat-7.0.57    文件：TestRemoteProcessException.java    
@Before
public void setUp() throws Exception {
    channel1 = new GroupChannel();
    channel2 = new GroupChannel();
    listener1 = new Listener();
    channel2.addChannelListener(listener1);
    TesterUtil.addRandomDomain(new ManagedChannel[] {channel1, channel2});
    channel1.start(Channel.DEFAULT);
    channel2.start(Channel.DEFAULT);
}