core/src/main/java/org/elasticsearch/cluster/service/ClusterService.java
public void remove(ClusterStateListener listener) {
        clusterStateListeners.remove(listener);
        priorityClusterStateListeners.remove(listener);
        lastClusterStateListeners.remove(listener);
        postAppliedListeners.remove(listener);
        for (Iterator<NotifyTimeout> it = onGoingTimeouts.iterator(); it.hasNext(); ) {
            NotifyTimeout timeout = it.next();
            if (timeout.listener.equals(listener)) {
                timeout.cancel();
                it.remove();
            }
        }
    }
/**
     * Removes a listener for updated cluster states.
     */
Removes a listener for updated cluster states.
Removes a listener for updated cluster states .
public void remove(ClusterStateListener listener) {
        clusterStateListeners.remove(listener);
        priorityClusterStateListeners.remove(listener);
        lastClusterStateListeners.remove(listener);
        postAppliedListeners.remove(listener);
        for (Iterator<NotifyTimeout> it = onGoingTimeouts.iterator(); it.hasNext(); ) {
            NotifyTimeout timeout = it.next();
            if (timeout.listener.equals(listener)) {
                timeout.cancel();
                it.remove();
            }
        }
    }
public void remove ( ClusterStateListener listener ) { clusterStateListeners . remove ( listener ) ; priorityClusterStateListeners . remove ( listener ) ; lastClusterStateListeners . remove ( listener ) ; postAppliedListeners . remove ( listener ) ; for ( Iterator < NotifyTimeout > it = onGoingTimeouts . iterator ( ) ; it . hasNext ( ) ; ) { NotifyTimeout timeout = it . next ( ) ; if ( timeout . listener . equals ( listener ) ) { timeout . cancel ( ) ; it . remove ( ) ; } } }
Removes a listener for updated cluster states.
Removes a listener for updated cluster states .