Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-1822 Renamed reference to MockProcessorContext#setNumThreads to setMaxConcurrentTasks after refactor.

This commit is contained in:
Andy LoPresto 2016-05-13 19:24:07 -07:00
parent 12bbe82381
commit bdbc4bab04
No known key found for this signature in database
GPG Key ID: 3C6EF65B2F7DEF69
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java
View File

@ -43,7 +43,6 @@ import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import org.apache.nifi.annotation.behavior.TriggerSerially; import org.apache.nifi.annotation.behavior.TriggerSerially;
import org.apache.nifi.annotation.lifecycle.OnAdded; import org.apache.nifi.annotation.lifecycle.OnAdded;
import org.apache.nifi.annotation.lifecycle.OnConfigurationRestored; import org.apache.nifi.annotation.lifecycle.OnConfigurationRestored;
@ -402,7 +401,7 @@ public class StandardProcessorTestRunner implements TestRunner {
@Override @Override
public void enqueue(final String data) { public void enqueue(final String data) {
enqueue(data.getBytes(StandardCharsets.UTF_8), Collections.<String, String> emptyMap()); enqueue(data.getBytes(StandardCharsets.UTF_8), Collections.emptyMap());
} }
@Override @Override
@ -531,7 +530,7 @@ public class StandardProcessorTestRunner implements TestRunner {
} }
this.numThreads = threadCount; this.numThreads = threadCount;
this.context.setNumThreads(threadCount); this.context.setMaxConcurrentTasks(threadCount);
} }
@Override @Override