Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-16 15:06:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-1822 Added variable max concurrent task field in MockProcessorContext because it was previously hardcoded to 1. Changed setNumThreads to setMaxConcurrentTasks to maintain naming convention.

Browse Source
This commit is contained in:
Andy LoPresto 2016-05-13 19:03:34 -07:00
parent fd9120c28b
commit 8c5ba51128
No known key found for this signature in database
GPG Key ID: 3C6EF65B2F7DEF69
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
nifi-mock/src/main/java/org/apache/nifi/util/MockProcessContext.java
View File

@ -27,7 +27,6 @@ import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import org.apache.nifi.attribute.expression.language.Query;
import org.apache.nifi.attribute.expression.language.Query.Range;
import org.apache.nifi.components.ConfigurableComponent;
@ -55,7 +54,8 @@ public class MockProcessContext extends MockControllerServiceLookup implements S
private boolean allowExpressionValidation = true;
private volatile boolean incomingConnection = true;
private volatile boolean nonLoopConnection = true;
private int numThreads = 1;
private int maxConcurrentTasks = 1;
private volatile Set<Relationship> connections = new HashSet<>();
private volatile Set<Relationship> unavailableRelationships = new HashSet<>();
@ -175,7 +175,7 @@ public class MockProcessContext extends MockControllerServiceLookup implements S
@Override
public int getMaxConcurrentTasks() {
return numThreads;
return maxConcurrentTasks;
}
public void setAnnotationData(final String annotationData) {
@ -362,7 +362,7 @@ public class MockProcessContext extends MockControllerServiceLookup implements S
return "";
}
protected void setNumThreads(int numThreads) {
this.numThreads = numThreads;
protected void setMaxConcurrentTasks(int maxConcurrentTasks) {
this.maxConcurrentTasks = maxConcurrentTasks;
}
}