Project

General

Profile

1
package eu.dnetlib.msro.workflows.util;
2

    
3
import javax.xml.ws.wsaddressing.W3CEndpointReference;
4

    
5
import eu.dnetlib.enabling.resultset.ResultSetFactory;
6
import eu.dnetlib.msro.workflows.resultset.ProcessCountingResultSetListener;
7

    
8
public class ResultsetProgressProvider implements ProgressProvider {
9

    
10
	private W3CEndpointReference epr;
11
	private ProcessCountingResultSetListener listener;
12
		
13
	public ResultsetProgressProvider(ResultSetFactory resultSetFactory,	ProcessCountingResultSetListener listener) {
14
		super();
15
		this.epr = resultSetFactory.createResultSet(listener);
16
		this.listener = listener;
17
	}
18

    
19
	@Override
20
	public int getTotalValue() {
21
		return listener.getSize();
22
	}
23

    
24
	@Override
25
	public int getCurrentValue() {
26
		return listener.getCount();
27
	}
28

    
29
	@Override
30
	public boolean isInaccurate() {
31
		return listener.isInaccurate();
32
	}
33

    
34
	public W3CEndpointReference getEpr() {
35
		return epr;
36
	}
37

    
38
	public void setEpr(W3CEndpointReference epr) {
39
		this.epr = epr;
40
	}
41

    
42
	public ProcessCountingResultSetListener getListener() {
43
		return listener;
44
	}
45

    
46
	public void setListener(ProcessCountingResultSetListener listener) {
47
		this.listener = listener;
48
	}
49

    
50
}
(3-3/7)