Examples of CatalogInfo

org.geoserver.catalog.CatalogInfo
Base interface for all catalog objects. @author Justin Deoliveira, OpenGeo
org.geotools.gtcatalog.CatalogInfo

Examples of org.geoserver.catalog.CatalogInfo

        final Properties options = getProperties();


        try {
            // check if we may publish also the file
          GeoServerResourceLoader loader = GeoServerExtensions.bean(GeoServerResourceLoader.class);
            final CatalogInfo info = event.getSource();
            if (info instanceof StyleInfo) {
                final StyleInfo sInfo=((StyleInfo) info);
                WorkspaceInfo wInfo =sInfo.getWorkspace();
                File styleFile=null;

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

        Properties options = getProperties();


        try {
            // check if we may publish also the file
          GeoServerResourceLoader loader = GeoServerExtensions.bean(GeoServerResourceLoader.class);
            final CatalogInfo info = event.getSource();
            if (info instanceof StyleInfo) {
                // build local datadir file style path
                final String canonicalStyleFileName = File.separator + "styles" + File.separator
                        + ((StyleInfo) info).getFilename();

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

    try {
      if (event instanceof CatalogRemoveEvent) {
        final CatalogRemoveEvent removeEv = ((CatalogRemoveEvent) event);


        // get the source
        final CatalogInfo info = removeEv.getSource();


        // disable the producer to avoid recursion
        producer.disable();
        // remove the selected CatalogInfo
        JMSCatalogRemoveEventHandler.remove(catalog, info, getProperties());

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

    try {
      if (event instanceof CatalogAddEvent) {
        final CatalogAddEvent addEv = ((CatalogAddEvent) event);
        
        // get the source from the incoming event
        final CatalogInfo info = addEv.getSource();
        // disable the producer to avoid recursion
        producer.disable();
        
        // add the incoming CatalogInfo to the local catalog
        JMSCatalogAddEventHandler.add(catalog, info);

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

    
    final Object source= xstream.fromXML(s);
    if (source instanceof CatalogEvent) {
      final CatalogEvent ev = (CatalogEvent) source;
      if (LOGGER.isLoggable(Level.FINE)) {
        final CatalogInfo info = ev.getSource();
        LOGGER.fine("Incoming message event of type CatalogEvent: "
            + info.getId());
      }
      return ev;
    } else {
      throw new JMSException("Unable to deserialize the following object:\n"+s);
    }

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

   */
  protected static void modify(final Catalog catalog,
      CatalogModifyEvent modifyEv) throws IllegalAccessException,
      InvocationTargetException, NoSuchMethodException {


    final CatalogInfo info = modifyEv.getSource();


    // check if name is changed
    String name = getOldName(catalog, modifyEv);


    if (info instanceof LayerGroupInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((LayerGroupInfo) info).getName();
      }


      final LayerGroupInfo localObject = catalog
          .getLayerGroupByName(name);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof LayerInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((LayerInfo) info).getName();
      }


      final LayerInfo localObject = catalog.getLayerByName(name);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof MapInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((MapInfo) info).getName();
      }


      final MapInfo localObject = catalog.getMapByName(name);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof NamespaceInfo) {


      final String uri;
      final Object uriObj = getOldValue(catalog, modifyEv, "uRI");
      if (uriObj != null) {
        uri = uriObj.toString();
      } else {
        // uri is unchanged
        uri = ((NamespaceInfo) info).getURI();
      }
      final NamespaceInfo localObject = catalog.getNamespaceByURI(uri);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " uri: " + uri + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof StoreInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((StoreInfo) info).getName();
      }
      // check if workspace is changed
      final WorkspaceInfo workspace;
      final Object objWorkpsace = getOldValue(catalog, modifyEv,
          "workspace");
      if (objWorkpsace != null) {
        workspace = (WorkspaceInfo) objWorkpsace;
      } else {
        // workspace is unchanged
        workspace = ((StoreInfo) info).getWorkspace();
      }
      
      final StoreInfo localObject;
      if (info instanceof CoverageStoreInfo) {
        localObject = catalog.getStoreByName(workspace, name,
            CoverageStoreInfo.class);
      } else if (info instanceof DataStoreInfo) {
        localObject = catalog.getStoreByName(workspace, name,
            DataStoreInfo.class);
      } else if (info instanceof WMSStoreInfo) {
        localObject = catalog.getStoreByName(workspace, name,
            WMSStoreInfo.class);
      } else {
        throw new IllegalArgumentException(
            "Unable to provide localization for the passed instance");
      }


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof ResourceInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((ResourceInfo) info).getName();
      }
      // check if namespace is changed
      final NamespaceInfo namespace;
      final Object objWorkpsace = getOldValue(catalog, modifyEv,
          "namespace");
      if (objWorkpsace != null) {
        namespace = (NamespaceInfo) objWorkpsace;
      } else {
        // workspace is unchanged
        namespace = ((ResourceInfo) info).getNamespace();
      }
      final ResourceInfo localObject;
      if (info instanceof CoverageInfo) {
        // coverage
        localObject = catalog.getCoverageByName(namespace, name);
      } else if (info instanceof FeatureTypeInfo) {
        // feature
        localObject = catalog.getFeatureTypeByName(namespace, name);
      } else if (info instanceof WMSLayerInfo) {
        // wmslayer
        localObject = catalog.getResourceByName(namespace, name,
            WMSLayerInfo.class);
      } else {
        throw new IllegalArgumentException(
            "Unable to provide localization for the passed instance");
      }
      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof StyleInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((StyleInfo) info).getName();
      }


      final StyleInfo localObject = catalog.getStyleByName(name);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof WorkspaceInfo) {


      // check if name is changed
      if (name == null) {
        // name is unchanged
        name = ((WorkspaceInfo) info).getName();
      }


      final WorkspaceInfo localObject = catalog.getWorkspaceByName(name);


      if (localObject == null) {
        throw new CatalogException("Unable to locate " + info
            + " named: " + name + " locally.");
      }


      BeanUtils.smartUpdate(localObject, modifyEv.getPropertyNames(),
          modifyEv.getNewValues());
      catalog.save(localObject);


    } else if (info instanceof CatalogInfo) {


      // change default workspace in the handled catalog
      /**
       * This piece of code was extracted from: {@link
       * org.geoserver.catalog.NamespaceWorkspaceConsistencyListener.
       * handleModifyEvent(CatalogModifyEvent)}
       */
      final List<String> properties = modifyEv.getPropertyNames();
      if (properties.contains("defaultNamespace")) {
        final NamespaceInfo newDefault = (NamespaceInfo) modifyEv
            .getNewValues().get(
                properties.indexOf("defaultNamespace"));
        if (newDefault != null) {
          final WorkspaceInfo ws = catalog
              .getWorkspaceByName(newDefault.getPrefix());
          if (ws != null && !catalog.getDefaultWorkspace().equals(ws)) {
            catalog.setDefaultWorkspace(ws);
          }
        }
      } else if (properties.contains("defaultWorkspace")) {
        final WorkspaceInfo newDefault = (WorkspaceInfo) modifyEv
            .getNewValues().get(
                properties.indexOf("defaultWorkspace"));
        if (newDefault != null) {
          final NamespaceInfo ns = catalog
              .getNamespaceByPrefix(newDefault.getName());
          if (ns != null && !catalog.getDefaultNamespace().equals(ns)) {
            catalog.setDefaultNamespace(ns);
          }
        }
      }


    } else {
      if (LOGGER.isLoggable(java.util.logging.Level.WARNING)) {
        LOGGER.warning("info - ID: " + info.getId() + " toString: "
            + info.toString());
      }
      throw new IllegalArgumentException("Bad incoming object: "
          + info.toString());
    }
  }

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

   * @return an Object representing the old value of the passed property or
   *         null if name is not changed or not exists at all
   */
  private static Object getOldValue(final Catalog catalog,
      final CatalogModifyEvent ev, final String oldProp) {
    final CatalogInfo service = ev.getSource();
    if (service == null) {
      throw new IllegalArgumentException("passed service is null");
    }
    // check if name is changed
    final List<String> props = ev.getPropertyNames();

View Full Code Here

Examples of org.geoserver.catalog.CatalogInfo

   * TODO: synchronization on catalog object
   */
  protected static void postModify(final Catalog catalog, CatalogPostModifyEvent modifyEv)
      throws IllegalAccessException, InvocationTargetException {
    
    final CatalogInfo info=modifyEv.getSource();


    if (info instanceof LayerGroupInfo) {
      
      final LayerGroupInfo localizedObject = CatalogUtils.localizeLayerGroup((LayerGroupInfo) info, catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));


  
    } else if (info instanceof LayerInfo) {
  
      final LayerInfo localizedObject=CatalogUtils.localizeLayer((LayerInfo) info, catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
      
    } else if (info instanceof MapInfo) {
  
      final MapInfo localizedObject = CatalogUtils.localizeMapInfo((MapInfo) info,catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
      
    } else if (info instanceof NamespaceInfo) {
  
      final NamespaceInfo localizedObject=CatalogUtils.localizeNamespace((NamespaceInfo) info, catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
      
    } else if (info instanceof StoreInfo) {
  
      final StoreInfo localizedObject=CatalogUtils.localizeStore((StoreInfo)info,catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
  
    } else if (info instanceof ResourceInfo) {
      
      final ResourceInfo localizedObject=CatalogUtils.localizeResource((ResourceInfo)info,catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
  
    } else if (info instanceof StyleInfo) {
  
      final StyleInfo localizedObject = CatalogUtils.localizeStyle((StyleInfo) info, catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
  
    } else if (info instanceof WorkspaceInfo) {
      
      final WorkspaceInfo localizedObject= CatalogUtils.localizeWorkspace((WorkspaceInfo) info, catalog);
      catalog.firePostModified(ModificationProxy.unwrap(localizedObject));
  
    } else if (info instanceof CatalogInfo) {


      if (LOGGER.isLoggable(java.util.logging.Level.WARNING)){
        LOGGER.warning("info - ID: "+info.getId()+" toString: "+info.toString());
      }
      
    } else {
      if (LOGGER.isLoggable(java.util.logging.Level.WARNING)){
        LOGGER.warning("info - ID: "+info.getId()+" toString: "+info.toString());
      }
      throw new IllegalArgumentException("Bad incoming object: "+info.toString());
    }
  }

View Full Code Here

Examples of org.geotools.gtcatalog.CatalogInfo

    if (adaptee.isAssignableFrom(CatalogInfo.class)) {
      if (info == null) {
        synchronized (this) {
          if (info == null) {
            try {
              info = new CatalogInfo(
                "skunk","Skunkworks",
                new URI("http://www.skunkworks.com"),new String[]{}
              );
            } 
            catch (URISyntaxException e) {}

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.