本文整理了Java中com.netflix.zuul.scriptManager.ZuulFilterDAOCassandra.notifyObservers()方法的一些代码示例，展示了ZuulFilterDAOCassandra.notifyObservers()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZuulFilterDAOCassandra.notifyObservers()方法的具体详情如下：
包路径：com.netflix.zuul.scriptManager.ZuulFilterDAOCassandra
类名称：ZuulFilterDAOCassandra
方法名：notifyObservers

ZuulFilterDAOCassandra.notifyObservers介绍

暂无

代码示例

代码示例来源：origin: com.netflix.zuul/zuul-core

notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "ACTIVATED NEW ZUUL FILTER id = " + filter_id + " revision = " + revision));
return getFilterInfoForFilter(filter_id, revision);

代码示例来源：origin: com.netflix.zuul/zuul-netflix

@Override
public FilterInfo deActivateFilter(String filter_id, int revision) throws Exception {
  FilterInfo filter = getFilterInfo(filter_id, revision);
  if (filter == null) throw new Exception("Filter not Found " + filter_id + "revision:" + revision);
  if (!filter.isCanary() && !filter.isActive()) {
    throw new Exception("Filter must be canary or active to deactivate" + filter_id + "revision:" + revision);
  }
  removeFilterIdFromIndex(ACTIVE_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filter.getRevision());
  removeFilterIdFromIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filter.getRevision());
  /* activate the revision */
  Map<String, Object> attributesForActivation = new HashMap<String, Object>();
  attributesForActivation.put("active", false);
  attributesForActivation.put("canary", false);
  cassandraGateway.upsert(filter_id + "_" + revision, attributesForActivation);
  setChanged();
  notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "DEACTIVATED ZUUL FILTER id = " + filter_id + " revision = " + revision));
  return getFilterInfoForFilter(filter_id, revision);
}

代码示例来源：origin: com.netflix.zuul/zuul-core

@Override
public FilterInfo deActivateFilter(String filter_id, int revision) throws Exception {
  FilterInfo filter = getFilterInfo(filter_id, revision);
  if (filter == null) throw new Exception("Filter not Found " + filter_id + "revision:" + revision);
  if (!filter.isCanary() && !filter.isActive()) {
    throw new Exception("Filter must be canary or active to deactivate" + filter_id + "revision:" + revision);
  }
  removeFilterIdFromIndex(ACTIVE_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filter.getRevision());
  removeFilterIdFromIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filter.getRevision());
  /* activate the revision */
  Map<String, Object> attributesForActivation = new HashMap<String, Object>();
  attributesForActivation.put("active", false);
  attributesForActivation.put("canary", false);
  cassandraGateway.upsert(filter_id + "_" + revision, attributesForActivation);
  setChanged();
  notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "DEACTIVATED ZUUL FILTER id = " + filter_id + " revision = " + revision));
  return getFilterInfoForFilter(filter_id, revision);
}

代码示例来源：origin: com.netflix.zuul/zuul-netflix

notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "ACTIVATED NEW ZUUL FILTER id = " + filter_id + " revision = " + revision));
return getFilterInfoForFilter(filter_id, revision);

代码示例来源：origin: com.netflix.zuul/zuul-netflix

@Override
public FilterInfo setCanaryFilter(String filter_id, int revision) {
  ArrayList<Integer> revisionsToDeactivate = new ArrayList<Integer>();
  FilterInfo filterInfo = getCanaryScriptForFilter(filter_id);
  if (filterInfo != null) {
    revisionsToDeactivate.add(filterInfo.getRevision());
    removeFilterIdFromIndex(ACTIVE_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filterInfo.getRevision());
    removeFilterIdFromIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filterInfo.getRevision());
  }
  /* activate the revision */
  Map<String, Object> attributesForActivation = new HashMap<String, Object>();
  attributesForActivation.put("canary", true);
  attributesForActivation.put("active", false);
  cassandraGateway.upsert(filter_id + "_" + revision, attributesForActivation);
  addFilterIdToIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + revision);
  /* de-activate previously active revisions */
  // do this AFTER activating so we don't allow a period where no active scripts will respond
  for (int revisionToDeactivate : revisionsToDeactivate) {
    // do NOT deactivate if we just activated this (can occur if someone calls this twice in a row, cleaning up bad data, etc)
    if (revisionToDeactivate != revision) {
      Map<String, Object> attributesForDeactivation = new HashMap<String, Object>();
      attributesForDeactivation.put("canary", false);
      cassandraGateway.upsert(filter_id + "_" + revisionToDeactivate, attributesForDeactivation);
    }
  }
  setChanged();
  notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "CANARY FILTER SET id = " + filter_id + "revision = " + revision));
  return getFilterInfoForFilter(filter_id, revision);
}

代码示例来源：origin: com.netflix.zuul/zuul-core

@Override
public FilterInfo setCanaryFilter(String filter_id, int revision) {
  ArrayList<Integer> revisionsToDeactivate = new ArrayList<Integer>();
  FilterInfo filterInfo = getCanaryScriptForFilter(filter_id);
  if (filterInfo != null) {
    revisionsToDeactivate.add(filterInfo.getRevision());
    removeFilterIdFromIndex(ACTIVE_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filterInfo.getRevision());
    removeFilterIdFromIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + filterInfo.getRevision());
  }
  /* activate the revision */
  Map<String, Object> attributesForActivation = new HashMap<String, Object>();
  attributesForActivation.put("canary", true);
  attributesForActivation.put("active", false);
  cassandraGateway.upsert(filter_id + "_" + revision, attributesForActivation);
  addFilterIdToIndex(CANARY_SCRIPTS + ZuulApplicationInfo.getApplicationName(), filter_id + "_" + revision);
  /* de-activate previously active revisions */
  // do this AFTER activating so we don't allow a period where no active scripts will respond
  for (int revisionToDeactivate : revisionsToDeactivate) {
    // do NOT deactivate if we just activated this (can occur if someone calls this twice in a row, cleaning up bad data, etc)
    if (revisionToDeactivate != revision) {
      Map<String, Object> attributesForDeactivation = new HashMap<String, Object>();
      attributesForDeactivation.put("canary", false);
      cassandraGateway.upsert(filter_id + "_" + revisionToDeactivate, attributesForDeactivation);
    }
  }
  setChanged();
  notifyObservers(new ZuulEvent("ZUUL_SCRIPT_CHANGE", "CANARY FILTER SET id = " + filter_id + "revision = " + revision));
  return getFilterInfoForFilter(filter_id, revision);
}