Changeset 7909 for RevitalizationWS


Ignore:
Timestamp:
22/03/11 16:41:51 (8 years ago)
Author:
mnagni
Message:

Bug fixes for CSW ingest and JMSConsumer

Location:
RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/ejb/JMSConsumer.java

    r7908 r7909  
    8686 
    8787                        if ((getObject(objMessage) instanceof IngestRequest)) { 
    88                                 hiProcess = ((InvokeProcess) getObject(objMessage)).getHiProcess(); 
    8988                                IngesterImpl ingester = new IngesterImpl((IngestRequest) getObject(objMessage)); 
     89                                hiProcess = ingester.getHiProcess(); 
    9090                                executor.invoke((InvokeProcess) ingester); 
    9191                        } 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/harvest/ProviderAdapter.java

    r7505 r7909  
    9292        } 
    9393 
    94         @SuppressWarnings("unchecked") 
     94        @SuppressWarnings("rawtypes") 
    9595        private ProviderAdapterHelper getHelper(Class<?> clazz) throws NdgExecutionException { 
    9696                return ProviderAdapterFactory.getProviderAdapterHelper(clazz); 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/harvest/ProviderAdapterFactory.java

    r7505 r7909  
    1919public class ProviderAdapterFactory { 
    2020 
    21         @SuppressWarnings("unchecked") 
     21        @SuppressWarnings("rawtypes") 
    2222        public static ProviderAdapterHelper  
    2323                        getProviderAdapterHelper(Class<?> clazz) throws NdgExecutionException { 
  • RevitalizationWS/ws/DPWS/trunk/src/main/java/ndg/services/revitalization/harvest/csw/CSWHarvester.java

    r7908 r7909  
    1111package ndg.services.revitalization.harvest.csw; 
    1212 
    13 import java.io.BufferedInputStream; 
    1413import java.io.ByteArrayInputStream; 
    1514import java.io.ByteArrayOutputStream; 
     
    3938import ndg.services.revitalization.harvest.HarvesterBase; 
    4039import ndg.services.revitalization.jpa.HiProcess; 
     40import net.opengis.csw._202.ElementSetNameType; 
     41import net.opengis.csw._202.ElementSetType; 
    4142import net.opengis.csw._202.GetRecordsResponseType; 
    4243import net.opengis.csw._202.GetRecordsType; 
    4344import net.opengis.csw._202.ObjectFactory; 
     45import net.opengis.csw._202.QueryType; 
    4446import net.opengis.csw._202.ResultType; 
    4547 
     
    8991 
    9092        private BigInteger getHits() throws NdgExecutionException { 
    91                 BigInteger ret = new BigInteger("0"); 
    92                 recordsRequest.setResultType(ResultType.HITS);           
    93                 if (getResponse() == null || getResponse().getSearchResults() == null) { 
     93                recordsRequest.setResultType(ResultType.HITS); 
     94                GetRecordsResponseType response = getResponse(); 
     95                if (response == null || response.getSearchResults() == null) { 
    9496                        throw new NdgExecutionException(new NdgMessage("null.object", new Object[] { "getHits()" }, null)); 
    9597                } 
    96                 return getResponse().getSearchResults().getNumberOfRecordsMatched(); 
     98                return response.getSearchResults().getNumberOfRecordsMatched(); 
    9799        } 
    98100 
     
    155157                ret.setResultType(ResultType.RESULTS); 
    156158 
     159                QueryType qt = of.createQueryType(); 
    157160                if (getHarvestRequest().getQuery() != null) { 
    158                         ret.setAbstractQuery(of.createQuery(getHarvestRequest().getQuery())); 
    159                 } 
     161                        qt =getHarvestRequest().getQuery(); 
     162                } else { 
     163                        qt.getTypeNames().addAll(getHarvestRequest().getQueryTypeNames()); 
     164                        ElementSetNameType nameType = of.createElementSetNameType(); 
     165                        nameType.setValue(ElementSetType.BRIEF); 
     166                        qt.setElementSetName(nameType); 
     167                } 
     168                ret.setAbstractQuery(of.createQuery(qt)); 
    160169                recordsRequest = ret; 
    161170        } 
Note: See TracChangeset for help on using the changeset viewer.