Project

General

Profile

« Previous | Next » 

Revision 52037

Added by Alessia Bardi almost 6 years ago

spaces for human readability

View differences:

modules/dnet-msro-service/trunk/src/main/java/eu/dnetlib/msro/workflows/nodes/mdstore/FetchMDStoreRecordsJobNode.java
42 42 
		final Long dateFromFilter = token.getFullEnv().getAttribute("DateFromFilter", Long.class);
43 43 

  		




  44
  44
  
    
		if (dateFromFilter!= null) {


  		




  45
  
  
    
			log.info("From Filter activated, from:"+dateFromFilter);


  		




  
  45
  
    
			log.info("From Filter activated, from: "+dateFromFilter);


  		




  46
  46
  
    
		}


  		




  47
  47
  
    

  		




  48
  
  
    

  		




  49
  
  
    

  		




  50
  48
  
    
		final MDStoreService mdStoreService = serviceLocator.getService(MDStoreService.class, getMdId());


  		




  51
  49
  
    
		int size = mdStoreService.size(getMdId());


  		




  52
  50
  
    

  		




  53
  51
  
    
		token.getEnv().setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "sourceSize", size);


  		




  54
  52
  
    
		log.info(String.format("getting MDRecords from: %s, sourceSize: %s", getMdId(), size));


  		




  55
  53
  
    

  		




  56
  
  
    
		final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), dateFromFilter!=null?""+dateFromFilter:"", "", "");


  		




  
  54
  
    
		final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), dateFromFilter != null ? "" + dateFromFilter : "", "", "");


  		




  57
  55
  
    
		if (epr == null) { throw new MSROException("unable to read MDRecords from: " + getMdId()); }


  		




  58
  56
  
    
		token.getEnv().setAttribute(getEprParam(), epr.toString());


  		




  59
  57
  
    
		return Arc.DEFAULT_ARC;


  		












Also available in:  Unified diff