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

NIFI-1237 Reducing number of messages sent in testBatching() to be less than size of ListenSyslog's internal queue 

Signed-off-by: joewitt <joewitt@apache.org>
This commit is contained in:
Bryan Bende 2015-12-01 21:24:32 -05:00 committed by joewitt
parent ff5330d7f2
commit 6a8c2dba12
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java
View File

@ -230,7 +230,9 @@ public class TestListenSyslog {
final ProcessContext context = runner.getProcessContext();
proc.onScheduled(context);
final int numMessages = 20;
// the processor has internal blocking queue with capacity 10 so we have to send
// less than that since we are sending all messages before the processors ever runs
final int numMessages = 5;
final int port = proc.getPort();
Assert.assertTrue(port > 0);
@ -251,7 +253,7 @@ public class TestListenSyslog {
final String content = new String(flowFile.toByteArray(), StandardCharsets.UTF_8);
final String[] splits = content.split("\\|");
Assert.assertEquals(20, splits.length);
Assert.assertEquals(numMessages, splits.length);
final List<ProvenanceEventRecord> events = runner.getProvenanceEvents();
Assert.assertNotNull(events);