org.geoserver.config.GeoServer.addListener()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(141)

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

GeoServer.addListener介绍

[英]Adds a listener to the configuration.
[中]将侦听器添加到配置中。

代码示例

代码示例来源:origin: geoserver/geoserver

public void initialize(GeoServer geoServer) throws Exception {
  geoServer.addListener(
      new ConfigurationListenerAdapter() {

代码示例来源:origin: geoserver/geoserver

public UpdateSequenceListener(GeoServer geoServer) {
  this.geoServer = geoServer;
  geoServer.getCatalog().addListener(this);
  geoServer.addListener(this);
}

代码示例来源:origin: geoserver/geoserver

@Override
public void initialize(GeoServer geoServer) throws Exception {
  // Consider moving earlier to make use of the requested LockProvider during initial
  // configuration
  String lockProviderName = geoServer.getGlobal().getLockProviderName();
  setLockProvider(lockProviderName);
  geoServer.addListener(listener);
}

代码示例来源:origin: geoserver/geoserver

public void initialize(GeoServer geoServer) throws Exception {
  initJAI(geoServer.getGlobal().getJAI());
  geoServer.addListener(
      new ConfigurationListenerAdapter() {
        public void handleGlobalChange(
            GeoServerInfo global,
            List<String> propertyNames,
            List<Object> oldValues,
            List<Object> newValues) {
          if (propertyNames.contains(
              "jAI")) { // TODO: check why the propertyname is reported as jAI
            // instead of JAI
            // Make sure to proceed with JAI init
            // only in case the global change involved that section
            initJAI(global.getJAI());
          }
        }
      });
}

代码示例来源:origin: geoserver/geoserver

protected void loadGeoServer(final GeoServer geoServer, XStreamPersister xp) throws Exception {
  if (listener == null) {
    // add event listener which persists changes
    final List<XStreamServiceLoader> loaders =
        GeoServerExtensions.extensions(XStreamServiceLoader.class);
    listener = new ServicePersister(loaders, geoServer);
  } else {
    // avoid re-dumping all service config files during load,
    // we'll attach it back once done
    geoserver.removeListener(listener);
  }
  try {
    if (this.configPersister != null) {
      // avoid having the persister write down new config files while we read the config,
      // otherwise it'll dump it back in xml files
      geoserver.removeListener(configPersister);
    } else {
      // lazy creation of the persisters at the first need
      this.configPersister = new GeoServerConfigPersister(resourceLoader, xp);
    }
    readConfiguration(geoServer, xp);
  } finally {
    // attach back the catalog persister and the service one
    geoserver.addListener(configPersister);
    geoserver.addListener(listener);
  }
}

代码示例来源:origin: geoserver/geoserver

public void initialize(GeoServer geoServer) throws Exception {
  this.gs = geoServer;
  final GeoServerInfo geoserverInfo = geoServer.getGlobal();
  CoverageAccessInfo coverageAccess = geoserverInfo.getCoverageAccess();
  if (coverageAccess == null) {
    coverageAccess = new CoverageAccessInfoImpl();
    geoserverInfo.setCoverageAccess(coverageAccess);
  }
  initCoverage(coverageAccess);
  geoServer.addListener(
      new ConfigurationListenerAdapter() {
        public void handleGlobalChange(
            GeoServerInfo global,
            List<String> propertyNames,
            List<Object> oldValues,
            List<Object> newValues) {
          if (propertyNames.contains("coverageAccess")) {
            // Make sure to proceed with coverageAccess init
            // only in case the global change involved that section
            initCoverage(global.getCoverageAccess());
          }
        }
        @Override
        public void handlePostGlobalChange(GeoServerInfo global) {
          // No need to handle that change too
        }
      });
}

代码示例来源:origin: geoserver/geoserver

@Override
protected void onSetUp(SystemTestData testData) throws Exception {
  GeoServer geoServer = getGeoServer();
  geoServer.addListener(
      new ServicePersister(
          (List) Arrays.asList(new ServiceLoader(getResourceLoader())), geoServer));
}

代码示例来源:origin: geoserver/geoserver

geoServer.addListener(
    new ConfigurationListenerAdapter() {
      @Override

代码示例来源:origin: geoserver/geoserver

geoServer.addListener(p);

代码示例来源:origin: org.geoserver.extension/gs-wps-core

public WpsAccessRuleDAO(GeoServer gs) throws IOException {
  this.gs = gs;
  gs.addListener(this);
}

代码示例来源:origin: org.geoserver/jms-geoserver

/**
 * 
 * @param topicTemplate the JmsTemplate object used to send message to the topic queue
 * @param geoserver
 * @param props properties to attach to all the message. May contains at least the producer name which should be unique.
 */
public JMSConfigurationListener(final GeoServer geoserver, final JMSPublisher jmsPublisher) {
  super();
  // store GeoServer reference
  this.geoserver = geoserver;
  // add this as geoserver listener
  this.geoserver.addListener(this);
  // the publisher
  this.jmsPublisher = jmsPublisher;
}

代码示例来源:origin: org.geoserver/gs-jms-geoserver

/**
 * 
 * @param topicTemplate the JmsTemplate object used to send message to the topic queue
 * @param geoserver
 * @param props properties to attach to all the message. May contains at least the producer name which should be unique.
 */
public JMSConfigurationListener(final GeoServer geoserver, final JMSPublisher jmsPublisher) {
  super();
  // store GeoServer reference
  this.geoserver = geoserver;
  // add this as geoserver listener
  this.geoserver.addListener(this);
  // the publisher
  this.jmsPublisher = jmsPublisher;
}

代码示例来源:origin: org.geoserver/gs-wms

public QuickTileCache(GeoServer geoServer) {
  geoServer.addListener(
      new ConfigurationListenerAdapter() {
        public void handleGlobalChange(
            GeoServerInfo global,
            List<String> propertyNames,
            List<Object> oldValues,
            List<Object> newValues) {
          tileCache.clear();
        }
        public void handleServiceChange(
            ServiceInfo service,
            List<String> propertyNames,
            List<Object> oldValues,
            List<Object> newValues) {
          tileCache.clear();
        }
        public void reloaded() {
          tileCache.clear();
        }
      });
}

代码示例来源:origin: org.geoserver.extension/wps-core

public void initialize(final GeoServer geoServer) throws Exception {
  initWPS(geoServer.getService(WPSInfo.class));
  geoServer.addListener(new ConfigurationListenerAdapter() {
    public void handleGlobalChange(GeoServerInfo global, List<String> propertyNames,
        List<Object> oldValues, List<Object> newValues) {
      initWPS(geoServer.getService(WPSInfo.class));
    }
    @Override
    public void handlePostGlobalChange(GeoServerInfo global) {
      initWPS(geoServer.getService(WPSInfo.class));
    }
  });
}

代码示例来源:origin: org.geoserver.extension/gs-wps-core

public void initialize(final GeoServer geoServer) throws Exception {
  initWPS(geoServer.getService(WPSInfo.class), geoServer);
  geoServer.addListener(
      new ConfigurationListenerAdapter() {
        @Override
        public void handlePostGlobalChange(GeoServerInfo global) {
          initWPS(geoServer.getService(WPSInfo.class), geoServer);
        }
      });
}

代码示例来源:origin: org.geoserver.extension/gs-wps-core

@Override
public void initialize(GeoServer geoServer) throws Exception {
  WPSInfo wps = geoServer.getService(WPSInfo.class);
  if (wps != null) {
    updateFilters(wps);
  }
  geoServer.addListener(
      new ConfigurationListenerAdapter() {
        @Override
        public void handlePostServiceChange(ServiceInfo service) {
          if (service instanceof WPSInfo) {
            updateFilters((WPSInfo) service);
          }
        }
      });
}

代码示例来源:origin: org.geoserver/jms-geoserver

public synchronized void setEnabled(boolean enabled) {
    this.enabled = enabled;
    if (enabled) {
      // remove Default persister
      if (persister != null) {
        geoserver.removeListener(persister);
        persister = null;
      }
      // remove Default listener
      if (listener != null) {
        geoserver.removeListener(listener);
        listener = null;
      }
    } else {
      if (listener == null) {
        // add event listener which persists changes
        final List<XStreamServiceLoader> loaders = GeoServerExtensions
            .extensions(XStreamServiceLoader.class);
        listener = new ServicePersister(loaders, geoserver);
        geoserver.addListener(listener);
      }
      if (persister == null) {
        persister = new GeoServerPersister(resourceLoader, xpf.createXMLPersister());
        // attach back the persister
        geoserver.addListener(persister);
      }
    }
  }
}

代码示例来源:origin: org.geoserver/gs-jms-geoserver

public synchronized void enable(boolean enabled) {
    this.enabled = enabled;
    if (enabled) {
      // remove Default persister
      if (persister != null) {
        geoserver.removeListener(persister);
        persister = null;
      }
      // remove Default listener
      if (listener != null) {
        geoserver.removeListener(listener);
        listener = null;
      }
    } else {
      if (listener == null) {
        // add event listener which persists changes
        final List<XStreamServiceLoader> loaders = GeoServerExtensions
            .extensions(XStreamServiceLoader.class);
        listener = new ServicePersister(loaders, geoserver);
        geoserver.addListener(listener);
      }
      if (persister == null) {
        persister = new GeoServerPersister(resourceLoader,
            xpf.createXMLPersister());
        // attach back the persister
        geoserver.addListener(persister);
      }
    }
  }
}

代码示例来源:origin: org.geoserver.community/gs-hz-cluster

public HzSynchronizer(HzCluster cluster, GeoServer gs) {
  this.cluster = cluster;
  this.gs = gs;
  topic = cluster.getHz().getTopic("geoserver.config");
  topic.addMessageListener(this);
  executor = getNewExecutor();
  gs.addListener(this);
  gs.getCatalog().addListener(this);
}

代码示例来源:origin: org.geoserver.extension/gs-wps-core

geoServer.addListener(listener);

相关文章