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

项目：tomee 文件：SimpleTomEETcpCluster.java

@Override
protected void checkDefaults() {
    final List<ClusterListener> currentListeners = clusterListeners;
    final TomEEClusterListener tomEEClusterListener = SystemInstance.get().getComponent(TomEEClusterListener.class);
    if (currentListeners.size() == 1 && currentListeners.iterator().next() == tomEEClusterListener) {
        currentListeners.clear();
    }

    // else force the new cluster listener
    for (final ClusterListener clusterListener : currentListeners) {
        clusterListener.setCluster(this); // we don't care about TomEEClusterListener since it is stateless
    }
    if (getClusterDeployer() != null) {
        getClusterDeployer().setCluster(this);
    }

    super.checkDefaults();
    addClusterListener(tomEEClusterListener); // since that's a singleton and all listeners have to be unique (contains()) we can always add it
}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * Get the cluster listeners associated with this cluster. If this Array has
 * no listeners registered, a zero-length array is returned.
 */
public ClusterListener[] findClusterListeners() {
    if (clusterListeners.size() > 0) {
        ClusterListener[] listener = new ClusterListener[clusterListeners.size()];
        clusterListeners.toArray(listener);
        return listener;
    } else
        return new ClusterListener[0];

}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * Add cluster message listener and register cluster to this listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#addClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void addClusterListener(ClusterListener listener) {
    if (listener != null && !clusterListeners.contains(listener)) {
        clusterListeners.add(listener);
        listener.setCluster(this);
    }
}

项目：tomcat7 文件：SimpleTcpCluster.java

/**
 * Remove message listener and deregister Cluster from listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#removeClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void removeClusterListener(ClusterListener listener) {
    if (listener != null) {
        clusterListeners.remove(listener);
        listener.setCluster(null);
    }
}

项目：tomcat7 文件：SimpleTcpCluster.java

public void messageReceived(ClusterMessage message) {

        if (log.isDebugEnabled() && message != null)
            log.debug("Assuming clocks are synched: Replication for "
                    + message.getUniqueId() + " took="
                    + (System.currentTimeMillis() - (message).getTimestamp())
                    + " ms.");

        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator();
                    iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners
                fireLifecycleEvent(RECEIVE_MESSAGE_FAILURE_EVENT,
                        new SendMessageData(message, dest, null));
                if (log.isDebugEnabled()) {
                    log.debug("Message " + message.toString() + " from type "
                            + message.getClass().getName()
                            + " transfered but no listener registered");
                }
            }
        }
        return;
    }

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

/**
 * Get the cluster listeners associated with this cluster. If this Array has
 * no listeners registered, a zero-length array is returned.
 */
public ClusterListener[] findClusterListeners() {
    if (clusterListeners.size() > 0) {
        ClusterListener[] listener = new ClusterListener[clusterListeners.size()];
        clusterListeners.toArray(listener);
        return listener;
    } else
        return new ClusterListener[0];

}

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

/**
 * Add cluster message listener and register cluster to this listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#addClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void addClusterListener(ClusterListener listener) {
    if (listener != null && !clusterListeners.contains(listener)) {
        clusterListeners.add(listener);
        listener.setCluster(this);
    }
}

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

/**
 * Remove message listener and deregister Cluster from listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#removeClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void removeClusterListener(ClusterListener listener) {
    if (listener != null) {
        clusterListeners.remove(listener);
        listener.setCluster(null);
    }
}

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

public void messageReceived(ClusterMessage message) {

        if (log.isDebugEnabled() && message != null)
            log.debug("Assuming clocks are synched: Replication for "
                    + message.getUniqueId() + " took="
                    + (System.currentTimeMillis() - (message).getTimestamp())
                    + " ms.");

        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator();
                    iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners
                fireLifecycleEvent(RECEIVE_MESSAGE_FAILURE_EVENT,
                        new SendMessageData(message, dest, null));
                if (log.isDebugEnabled()) {
                    log.debug("Message " + message.toString() + " from type "
                            + message.getClass().getName()
                            + " transfered but no listener registered");
                }
            }
        }
        return;
    }

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * Get the cluster listeners associated with this cluster. If this Array has
 * no listeners registered, a zero-length array is returned.
 */
public ClusterListener[] findClusterListeners() {
    if (clusterListeners.size() > 0) {
        ClusterListener[] listener = new ClusterListener[clusterListeners.size()];
        clusterListeners.toArray(listener);
        return listener;
    } else
        return new ClusterListener[0];

}

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * Add cluster message listener and register cluster to this listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#addClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void addClusterListener(ClusterListener listener) {
    if (listener != null && !clusterListeners.contains(listener)) {
        clusterListeners.add(listener);
        listener.setCluster(this);
    }
}

项目：lazycat 文件：SimpleTcpCluster.java

/**
 * Remove message listener and deregister Cluster from listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#removeClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void removeClusterListener(ClusterListener listener) {
    if (listener != null) {
        clusterListeners.remove(listener);
        listener.setCluster(null);
    }
}

项目：lazycat 文件：SimpleTcpCluster.java

public void messageReceived(ClusterMessage message) {

        if (log.isDebugEnabled() && message != null)
            log.debug("Assuming clocks are synched: Replication for " + message.getUniqueId() + " took="
                    + (System.currentTimeMillis() - (message).getTimestamp()) + " ms.");

        // invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator(); iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners
                fireLifecycleEvent(RECEIVE_MESSAGE_FAILURE_EVENT, new SendMessageData(message, dest, null));
                if (log.isDebugEnabled()) {
                    log.debug("Message " + message.toString() + " from type " + message.getClass().getName()
                            + " transfered but no listener registered");
                }
            }
        }
        return;
    }

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

/**
 * Get the cluster listeners associated with this cluster. If this Array has
 * no listeners registered, a zero-length array is returned.
 */
public ClusterListener[] findClusterListeners() {
    if (clusterListeners.size() > 0) {
        ClusterListener[] listener = new ClusterListener[clusterListeners.size()];
        clusterListeners.toArray(listener);
        return listener;
    } else
        return new ClusterListener[0];

}

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

/**
 * Add cluster message listener and register cluster to this listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#addClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void addClusterListener(ClusterListener listener) {
    if (listener != null && !clusterListeners.contains(listener)) {
        clusterListeners.add(listener);
        listener.setCluster(this);
    }
}

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

/**
 * Remove message listener and deregister Cluster from listener.
 * 
 * @see org.apache.catalina.ha.CatalinaCluster#removeClusterListener(org.apache.catalina.ha.ClusterListener)
 */
@Override
public void removeClusterListener(ClusterListener listener) {
    if (listener != null) {
        clusterListeners.remove(listener);
        listener.setCluster(null);
    }
}

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

public void messageReceived(ClusterMessage message) {

        if (log.isDebugEnabled() && message != null)
            log.debug("Assuming clocks are synched: Replication for "
                    + message.getUniqueId() + " took="
                    + (System.currentTimeMillis() - (message).getTimestamp())
                    + " ms.");

        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator();
                    iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners
                fireLifecycleEvent(RECEIVE_MESSAGE_FAILURE_EVENT,
                        new SendMessageData(message, dest, null));
                if (log.isDebugEnabled()) {
                    log.debug("Message " + message.toString() + " from type "
                            + message.getClass().getName()
                            + " transfered but no listener registered");
                }
            }
        }
        return;
    }