public class org.apache.nifi.processors.standard.TestDuplicateFlowFile extends java.lang.Object
{
public void <init>()
{
org.apache.nifi.processors.standard.TestDuplicateFlowFile v;
v := @this: org.apache.nifi.processors.standard.TestDuplicateFlowFile;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void test()
{
byte[] v;
org.apache.nifi.processors.standard.TestDuplicateFlowFile v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
int v, v;
java.lang.Object v, v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.processors.standard.TestDuplicateFlowFile;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/DuplicateFlowFile;");
v = <org.apache.nifi.processors.standard.DuplicateFlowFile: org.apache.nifi.components.PropertyDescriptor NUM_COPIES>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(100);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = "hello";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.DuplicateFlowFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 101);
v = <org.apache.nifi.processors.standard.DuplicateFlowFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = 1;
label:
if v > 100 goto label;
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("copy.index", v);
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(100);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("copy.index", "0");
return;
}
public void testNumberOfCopiesEL()
{
byte[] v;
org.apache.nifi.processors.standard.TestDuplicateFlowFile v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestDuplicateFlowFile$1 v;
java.lang.String v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestDuplicateFlowFile;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/DuplicateFlowFile;");
v = <org.apache.nifi.processors.standard.DuplicateFlowFile: org.apache.nifi.components.PropertyDescriptor NUM_COPIES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${num.copies}");
v = "hello";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = new org.apache.nifi.processors.standard.TestDuplicateFlowFile$1;
specialinvoke v.<org.apache.nifi.processors.standard.TestDuplicateFlowFile$1: void <init>(org.apache.nifi.processors.standard.TestDuplicateFlowFile)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.DuplicateFlowFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 101);
return;
}
}