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

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

本文整理了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

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

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

  1. public UpdateSequenceListener(GeoServer geoServer) {
  2. this.geoServer = geoServer;
  3. geoServer.getCatalog().addListener(this);
  4. geoServer.addListener(this);
  5. }

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

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

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

  1. public void initialize(GeoServer geoServer) throws Exception {
  2. initJAI(geoServer.getGlobal().getJAI());
  3. geoServer.addListener(
  4. new ConfigurationListenerAdapter() {
  5. public void handleGlobalChange(
  6. GeoServerInfo global,
  7. List<String> propertyNames,
  8. List<Object> oldValues,
  9. List<Object> newValues) {
  10. if (propertyNames.contains(
  11. "jAI")) { // TODO: check why the propertyname is reported as jAI
  12. // instead of JAI
  13. // Make sure to proceed with JAI init
  14. // only in case the global change involved that section
  15. initJAI(global.getJAI());
  16. }
  17. }
  18. });
  19. }

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

  1. protected void loadGeoServer(final GeoServer geoServer, XStreamPersister xp) throws Exception {
  2. if (listener == null) {
  3. // add event listener which persists changes
  4. final List<XStreamServiceLoader> loaders =
  5. GeoServerExtensions.extensions(XStreamServiceLoader.class);
  6. listener = new ServicePersister(loaders, geoServer);
  7. } else {
  8. // avoid re-dumping all service config files during load,
  9. // we'll attach it back once done
  10. geoserver.removeListener(listener);
  11. }
  12. try {
  13. if (this.configPersister != null) {
  14. // avoid having the persister write down new config files while we read the config,
  15. // otherwise it'll dump it back in xml files
  16. geoserver.removeListener(configPersister);
  17. } else {
  18. // lazy creation of the persisters at the first need
  19. this.configPersister = new GeoServerConfigPersister(resourceLoader, xp);
  20. }
  21. readConfiguration(geoServer, xp);
  22. } finally {
  23. // attach back the catalog persister and the service one
  24. geoserver.addListener(configPersister);
  25. geoserver.addListener(listener);
  26. }
  27. }

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

  1. public void initialize(GeoServer geoServer) throws Exception {
  2. this.gs = geoServer;
  3. final GeoServerInfo geoserverInfo = geoServer.getGlobal();
  4. CoverageAccessInfo coverageAccess = geoserverInfo.getCoverageAccess();
  5. if (coverageAccess == null) {
  6. coverageAccess = new CoverageAccessInfoImpl();
  7. geoserverInfo.setCoverageAccess(coverageAccess);
  8. }
  9. initCoverage(coverageAccess);
  10. geoServer.addListener(
  11. new ConfigurationListenerAdapter() {
  12. public void handleGlobalChange(
  13. GeoServerInfo global,
  14. List<String> propertyNames,
  15. List<Object> oldValues,
  16. List<Object> newValues) {
  17. if (propertyNames.contains("coverageAccess")) {
  18. // Make sure to proceed with coverageAccess init
  19. // only in case the global change involved that section
  20. initCoverage(global.getCoverageAccess());
  21. }
  22. }
  23. @Override
  24. public void handlePostGlobalChange(GeoServerInfo global) {
  25. // No need to handle that change too
  26. }
  27. });
  28. }

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

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

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

  1. geoServer.addListener(
  2. new ConfigurationListenerAdapter() {
  3. @Override

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

  1. geoServer.addListener(p);

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

  1. public WpsAccessRuleDAO(GeoServer gs) throws IOException {
  2. this.gs = gs;
  3. gs.addListener(this);
  4. }

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

  1. /**
  2. *
  3. * @param topicTemplate the JmsTemplate object used to send message to the topic queue
  4. * @param geoserver
  5. * @param props properties to attach to all the message. May contains at least the producer name which should be unique.
  6. */
  7. public JMSConfigurationListener(final GeoServer geoserver, final JMSPublisher jmsPublisher) {
  8. super();
  9. // store GeoServer reference
  10. this.geoserver = geoserver;
  11. // add this as geoserver listener
  12. this.geoserver.addListener(this);
  13. // the publisher
  14. this.jmsPublisher = jmsPublisher;
  15. }

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

  1. /**
  2. *
  3. * @param topicTemplate the JmsTemplate object used to send message to the topic queue
  4. * @param geoserver
  5. * @param props properties to attach to all the message. May contains at least the producer name which should be unique.
  6. */
  7. public JMSConfigurationListener(final GeoServer geoserver, final JMSPublisher jmsPublisher) {
  8. super();
  9. // store GeoServer reference
  10. this.geoserver = geoserver;
  11. // add this as geoserver listener
  12. this.geoserver.addListener(this);
  13. // the publisher
  14. this.jmsPublisher = jmsPublisher;
  15. }

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

  1. public QuickTileCache(GeoServer geoServer) {
  2. geoServer.addListener(
  3. new ConfigurationListenerAdapter() {
  4. public void handleGlobalChange(
  5. GeoServerInfo global,
  6. List<String> propertyNames,
  7. List<Object> oldValues,
  8. List<Object> newValues) {
  9. tileCache.clear();
  10. }
  11. public void handleServiceChange(
  12. ServiceInfo service,
  13. List<String> propertyNames,
  14. List<Object> oldValues,
  15. List<Object> newValues) {
  16. tileCache.clear();
  17. }
  18. public void reloaded() {
  19. tileCache.clear();
  20. }
  21. });
  22. }

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

  1. public void initialize(final GeoServer geoServer) throws Exception {
  2. initWPS(geoServer.getService(WPSInfo.class));
  3. geoServer.addListener(new ConfigurationListenerAdapter() {
  4. public void handleGlobalChange(GeoServerInfo global, List<String> propertyNames,
  5. List<Object> oldValues, List<Object> newValues) {
  6. initWPS(geoServer.getService(WPSInfo.class));
  7. }
  8. @Override
  9. public void handlePostGlobalChange(GeoServerInfo global) {
  10. initWPS(geoServer.getService(WPSInfo.class));
  11. }
  12. });
  13. }

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

  1. public void initialize(final GeoServer geoServer) throws Exception {
  2. initWPS(geoServer.getService(WPSInfo.class), geoServer);
  3. geoServer.addListener(
  4. new ConfigurationListenerAdapter() {
  5. @Override
  6. public void handlePostGlobalChange(GeoServerInfo global) {
  7. initWPS(geoServer.getService(WPSInfo.class), geoServer);
  8. }
  9. });
  10. }

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

  1. @Override
  2. public void initialize(GeoServer geoServer) throws Exception {
  3. WPSInfo wps = geoServer.getService(WPSInfo.class);
  4. if (wps != null) {
  5. updateFilters(wps);
  6. }
  7. geoServer.addListener(
  8. new ConfigurationListenerAdapter() {
  9. @Override
  10. public void handlePostServiceChange(ServiceInfo service) {
  11. if (service instanceof WPSInfo) {
  12. updateFilters((WPSInfo) service);
  13. }
  14. }
  15. });
  16. }

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

  1. public synchronized void setEnabled(boolean enabled) {
  2. this.enabled = enabled;
  3. if (enabled) {
  4. // remove Default persister
  5. if (persister != null) {
  6. geoserver.removeListener(persister);
  7. persister = null;
  8. }
  9. // remove Default listener
  10. if (listener != null) {
  11. geoserver.removeListener(listener);
  12. listener = null;
  13. }
  14. } else {
  15. if (listener == null) {
  16. // add event listener which persists changes
  17. final List<XStreamServiceLoader> loaders = GeoServerExtensions
  18. .extensions(XStreamServiceLoader.class);
  19. listener = new ServicePersister(loaders, geoserver);
  20. geoserver.addListener(listener);
  21. }
  22. if (persister == null) {
  23. persister = new GeoServerPersister(resourceLoader, xpf.createXMLPersister());
  24. // attach back the persister
  25. geoserver.addListener(persister);
  26. }
  27. }
  28. }
  29. }

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

  1. public synchronized void enable(boolean enabled) {
  2. this.enabled = enabled;
  3. if (enabled) {
  4. // remove Default persister
  5. if (persister != null) {
  6. geoserver.removeListener(persister);
  7. persister = null;
  8. }
  9. // remove Default listener
  10. if (listener != null) {
  11. geoserver.removeListener(listener);
  12. listener = null;
  13. }
  14. } else {
  15. if (listener == null) {
  16. // add event listener which persists changes
  17. final List<XStreamServiceLoader> loaders = GeoServerExtensions
  18. .extensions(XStreamServiceLoader.class);
  19. listener = new ServicePersister(loaders, geoserver);
  20. geoserver.addListener(listener);
  21. }
  22. if (persister == null) {
  23. persister = new GeoServerPersister(resourceLoader,
  24. xpf.createXMLPersister());
  25. // attach back the persister
  26. geoserver.addListener(persister);
  27. }
  28. }
  29. }
  30. }

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

  1. public HzSynchronizer(HzCluster cluster, GeoServer gs) {
  2. this.cluster = cluster;
  3. this.gs = gs;
  4. topic = cluster.getHz().getTopic("geoserver.config");
  5. topic.addMessageListener(this);
  6. executor = getNewExecutor();
  7. gs.addListener(this);
  8. gs.getCatalog().addListener(this);
  9. }

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

  1. geoServer.addListener(listener);

相关文章