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

Java 类org.apache.catalina.tribes.transport.ReplicationTransmitter 实例源码

项目：tomcat7    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    log.info("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：tomcat7    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    log.info("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：tomcat7    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：tomcat7    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    log.info("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    log.info("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.73-with-comment    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：class-guard    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    log.info("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：class-guard    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    log.info("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：class-guard    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：class-guard    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.57    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    log.info("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：apache-tomcat-7.0.57    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    log.info("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：apache-tomcat-7.0.57    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.57    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.57    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    log.info("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：apache-tomcat-7.0.57    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    log.info("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：apache-tomcat-7.0.57    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：apache-tomcat-7.0.57    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：wso2-axis2    文件：TribesClusteringAgent.java    
/**
 * Set the maximum number of retries, if message sending to a particular node fails
 */
private void setMaximumRetries() {
    Parameter maxRetriesParam = getParameter(TribesConstants.MAX_RETRIES);
    int maxRetries = 10;
    if (maxRetriesParam != null) {
        maxRetries = Integer.parseInt((String) maxRetriesParam.getValue());
    }
    ReplicationTransmitter replicationTransmitter =
            (ReplicationTransmitter) channel.getChannelSender();
    MultiPointSender multiPointSender = replicationTransmitter.getTransport();
    multiPointSender.setMaxRetryAttempts(maxRetries);
}
项目：WBSAirback    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveCount() throws Exception {
    System.out.println("Setting keep alive count to 0");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveCount(0);
    }
    sendMessages(1000,15000);
}
项目：WBSAirback    文件：TestGroupChannelSenderConnections.java    
@Test
public void testKeepAliveTime() throws Exception {
    System.out.println("Setting keep alive count to 1 second");
    for (int i = 0; i < channels.length; i++) {
        ReplicationTransmitter t = (ReplicationTransmitter)channels[0].getChannelSender();
        t.getTransport().setKeepAliveTime(1000);
    }
    sendMessages(2000,15000);
}
项目：WBSAirback    文件：TestMulticastPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_MULTICAST);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}
项目：WBSAirback    文件：TestUdpPackages.java    
@Test
public void testSingleDataSendNO_ACK() throws Exception {
    AbstractSender s1 =(AbstractSender) ((ReplicationTransmitter)channel1.getChannelSender()).getTransport();
    AbstractSender s2 =(AbstractSender) ((ReplicationTransmitter)channel2.getChannelSender()).getTransport();
    s1.setTimeout(Long.MAX_VALUE); //for debugging
    s2.setTimeout(Long.MAX_VALUE); //for debugging

    System.err.println("Starting Single package NO_ACK");
    channel1.send(new Member[] {channel2.getLocalMember(false)}, Data.createRandomData(1024),Channel.SEND_OPTIONS_UDP);
    Thread.sleep(500);
    System.err.println("Finished Single package NO_ACK ["+listener1.count+"]");
    assertEquals("Checking success messages.",1,listener1.count.get());
}