Project

General

Profile

« Previous | Next » 

Revision 60357

Added by Michele Artini over 3 years ago

Removed MessageType from Message

View differences:

SubmitDnetHadoopJobNode.java
11 11 
import com.googlecode.sarasvati.NodeToken;
12 12 
import com.googlecode.sarasvati.env.Env;
13 13 

  		




  
  14
  
    
import eu.dnetlib.dhp.message.Message;


  		




  14
  15
  
    
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;


  		




  15
  
  
    
import eu.dnetlib.message.Message;


  		




  16
  16
  
    
import eu.dnetlib.msro.openaireplus.workflows.nodes.dhp.message.DnetMessageManager;


  		




  17
  17
  
    
import eu.dnetlib.msro.workflows.hadoop.SubmitHadoopJobNode;


  		




  18
  18
  
    
import eu.dnetlib.msro.workflows.nodes.ProgressJobNode;


  		




  ......




  42
  42
  
    
	}


  		




  43
  43
  
    

  		




  44
  44
  
    
	private void updateProgressProvider() {


  		




  45
  
  
    
		final Message mess = dnetMessageManager.getOnGoingMessage(wfId);


  		




  
  45
  
    
		final Message mess = dnetMessageManager.findMessage(wfId);


  		




  46
  46
  
    
		if (mess != null && mess.getBody() != null) {


  		




  47
  47
  
    
			if (mess.getBody().containsKey("current")) {


  		




  48
  48
  
    
				try {


  		












Also available in:  Unified diff