public class org.apache.nifi.processors.standard.TestParseSyslog extends java.lang.Object
{
static final java.lang.String PRI;
static final java.lang.String SEV;
static final java.lang.String FAC;
static final java.lang.String TIME;
static final java.lang.String HOST;
static final java.lang.String IPV6SRC;
static final java.lang.String IPV4SRC;
static final java.lang.String BODY;
static final java.lang.String VALID_MESSAGE_RFC3164_0;
static final java.lang.String VALID_MESSAGE_RFC3164_1;
static final java.lang.String VALID_MESSAGE_RFC3164_2;
public void <init>()
{
org.apache.nifi.processors.standard.TestParseSyslog v;
v := @this: org.apache.nifi.processors.standard.TestParseSyslog;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testSuccessfulParse3164()
{
byte[] v;
org.apache.nifi.processors.standard.TestParseSyslog v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.ParseSyslog v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.syslog.attributes.SyslogAttributes v, v, v, v, v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseSyslog;
v = new org.apache.nifi.processors.standard.ParseSyslog;
specialinvoke v.<org.apache.nifi.processors.standard.ParseSyslog: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = "<34>Oct 13 15:43:23 localhost.home some message\n";
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.ParseSyslog: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseSyslog: 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 = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_BODY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "some message");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_FACILITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_HOSTNAME>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "localhost.home");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_PRIORITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "34");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_SEVERITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_TIMESTAMP>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "Oct 13 15:43:23");
return;
}
public void testValidIPv6Source()
{
byte[] v;
org.apache.nifi.processors.standard.TestParseSyslog v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.ParseSyslog v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.syslog.attributes.SyslogAttributes v, v, v, v, v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseSyslog;
v = new org.apache.nifi.processors.standard.ParseSyslog;
specialinvoke v.<org.apache.nifi.processors.standard.ParseSyslog: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = "<34>Oct 13 15:43:23 fe80::216:3300:eeaa:eeaa some message\n";
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.ParseSyslog: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseSyslog: 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 = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_BODY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "some message");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_FACILITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_HOSTNAME>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "fe80::216:3300:eeaa:eeaa");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_PRIORITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "34");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_SEVERITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_TIMESTAMP>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "Oct 13 15:43:23");
return;
}
public void testValidIPv4Source()
{
byte[] v;
org.apache.nifi.processors.standard.TestParseSyslog v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.ParseSyslog v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.syslog.attributes.SyslogAttributes v, v, v, v, v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseSyslog;
v = new org.apache.nifi.processors.standard.ParseSyslog;
specialinvoke v.<org.apache.nifi.processors.standard.ParseSyslog: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = "<34>Oct 13 15:43:23 8.8.4.4 some message\n";
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.ParseSyslog: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseSyslog: 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 = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_BODY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "some message");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_FACILITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_HOSTNAME>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "8.8.4.4");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_PRIORITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "34");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_SEVERITY>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.syslog.attributes.SyslogAttributes: org.apache.nifi.syslog.attributes.SyslogAttributes SYSLOG_TIMESTAMP>;
v = virtualinvoke v.<org.apache.nifi.syslog.attributes.SyslogAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "Oct 13 15:43:23");
return;
}
public void testInvalidMessage()
{
byte[] v;
org.apache.nifi.processors.standard.TestParseSyslog v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processors.standard.ParseSyslog v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.TestParseSyslog;
v = new org.apache.nifi.processors.standard.ParseSyslog;
specialinvoke v.<org.apache.nifi.processors.standard.ParseSyslog: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = "<hello> yesterday localhost\n";
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.ParseSyslog: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
}