Java 类org.apache.catalina.ha.ClusterValve 实例源码

项目：class-guard 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 * @throws Exception
 * @throws ClassNotFoundException
 */
protected void registerClusterValve() throws Exception {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                IntrospectionUtils.callMethodN(getContainer(), "addValve",
                        new Object[] { valve },
                        new Class[] { org.apache.catalina.Valve.class });

                valve.setCluster(this);
            }
        }
    }
}

项目：WBSAirback 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 * @throws Exception
 * @throws ClassNotFoundException
 */
protected void registerClusterValve() throws Exception {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                IntrospectionUtils.callMethodN(getContainer(), "addValve",
                        new Object[] { valve },
                        new Class[] { org.apache.catalina.Valve.class });

                valve.setCluster(this);
            }
        }
    }
}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 */
protected void registerClusterValve() {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                container.getPipeline().addValve(valve);
                valve.setCluster(this);
            }
        }
    }
}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 */
protected void unregisterClusterValve() {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            container.getPipeline().removeValve(valve);
            valve.setCluster(null);
        }
    }
}

项目：apache-tomcat-7.0.73-with-comment 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 */
protected void registerClusterValve() {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                container.getPipeline().addValve(valve);
                valve.setCluster(this);
            }
        }
    }
}

项目：apache-tomcat-7.0.73-with-comment 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 */
protected void unregisterClusterValve() {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            container.getPipeline().removeValve(valve);
            valve.setCluster(null);
        }
    }
}

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 */
protected void registerClusterValve() {
    if (container != null) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer() + " with class=" + valve.getClass().getName());
            if (valve != null) {
                container.getPipeline().addValve(valve);
                valve.setCluster(this);
            }
        }
    }
}

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 */
protected void unregisterClusterValve() {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer() + " with class=" + valve.getClass().getName());
        if (valve != null) {
            container.getPipeline().removeValve(valve);
            valve.setCluster(null);
        }
    }
}

项目：class-guard 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 * @throws Exception
 * @throws ClassNotFoundException
 */
protected void unregisterClusterValve() throws Exception {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            IntrospectionUtils.callMethodN(getContainer(), "removeValve",
                new Object[] { valve },
                new Class[] { org.apache.catalina.Valve.class });
            valve.setCluster(this);
        }
    }
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 */
protected void registerClusterValve() {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                container.getPipeline().addValve(valve);
                valve.setCluster(this);
            }
        }
    }
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 */
protected void unregisterClusterValve() {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            container.getPipeline().removeValve(valve);
            valve.setCluster(null);
        }
    }
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * register all cluster valve to host or engine
 */
protected void registerClusterValve() {
    if(container != null ) {
        for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
            ClusterValve valve = (ClusterValve) iter.next();
            if (log.isDebugEnabled())
                log.debug("Invoking addValve on " + getContainer()
                        + " with class=" + valve.getClass().getName());
            if (valve != null) {
                container.getPipeline().addValve(valve);
                valve.setCluster(this);
            }
        }
    }
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 */
protected void unregisterClusterValve() {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            container.getPipeline().removeValve(valve);
            valve.setCluster(null);
        }
    }
}

项目：WBSAirback 文件：SimpleTcpCluster.java

/**
 * unregister all cluster valve to host or engine
 * @throws Exception
 * @throws ClassNotFoundException
 */
protected void unregisterClusterValve() throws Exception {
    for (Iterator<Valve> iter = valves.iterator(); iter.hasNext();) {
        ClusterValve valve = (ClusterValve) iter.next();
        if (log.isDebugEnabled())
            log.debug("Invoking removeValve on " + getContainer()
                    + " with class=" + valve.getClass().getName());
        if (valve != null) {
            IntrospectionUtils.callMethodN(getContainer(), "removeValve",
                new Object[] { valve },
                new Class[] { org.apache.catalina.Valve.class });
            valve.setCluster(this);
        }
    }
}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：apache-tomcat-7.0.73-with-comment 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：class-guard 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：apache-tomcat-7.0.57 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：WBSAirback 文件：SimpleTcpCluster.java

/**
 * Add cluster valve 
 * Cluster Valves are only add to container when cluster is started!
 * @param valve The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * Add cluster valve Cluster Valves are only add to container when cluster
 * is started!
 * 
 * @param valve
 *            The new cluster Valve.
 */
@Override
public void addValve(Valve valve) {
    if (valve instanceof ClusterValve && (!valves.contains(valve)))
        valves.add(valve);
}