public class org.apache.nifi.processors.standard.TestPutSyslog extends java.lang.Object
{
private static final java.lang.String ADDRESS;
private static final java.lang.String LOCALHOST;
private static final java.lang.String MESSAGE_BODY;
private static final java.lang.String MESSAGE_PRIORITY;
private static final java.lang.String DEFAULT_PROTOCOL;
private static final java.lang.String TIMESTAMP;
private static final java.lang.String VERSION;
private static final java.lang.String SYSLOG_MESSAGE;
private static final java.lang.String VERSION_SYSLOG_MESSAGE;
private static final int MAX_FRAME_LENGTH;
private static final java.nio.charset.Charset CHARSET;
private static final java.lang.String DELIMITER;
private static final int POLL_TIMEOUT_SECONDS;
private org.apache.nifi.util.TestRunner runner;
private final org.apache.nifi.event.transport.configuration.TransportProtocol protocol;
private java.net.InetAddress address;
private int port;
private org.apache.nifi.event.transport.EventServer eventServer;
private java.util.concurrent.BlockingQueue messages;
public void <init>()
{
org.apache.nifi.event.transport.configuration.TransportProtocol v;
org.apache.nifi.processors.standard.TestPutSyslog v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.nifi.event.transport.configuration.TransportProtocol: org.apache.nifi.event.transport.configuration.TransportProtocol UDP>;
v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.configuration.TransportProtocol protocol> = v;
return;
}
public void setRunner() throws java.net.UnknownHostException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
java.net.InetAddress v, v;
org.apache.nifi.event.transport.netty.ByteArrayMessageNettyEventServerFactory v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v;
java.time.Duration v, v;
java.util.concurrent.BlockingQueue v;
java.util.concurrent.LinkedBlockingQueue v;
org.apache.nifi.event.transport.configuration.TransportProtocol v, v;
java.nio.charset.Charset v;
org.apache.nifi.event.transport.configuration.ShutdownQuietPeriod v;
org.apache.nifi.processors.standard.TestPutSyslog v;
int v, v;
java.lang.String v, v, v, v;
org.apache.nifi.event.transport.EventServer v, v;
org.apache.nifi.event.transport.configuration.ShutdownTimeout v;
org.apache.nifi.mock.MockComponentLogger v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = "\n";
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.nio.charset.Charset CHARSET>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.nifi.processors.standard.TestPutSyslog: java.util.concurrent.BlockingQueue messages> = v;
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getByName(java.lang.String)>("127.0.0.1");
v.<org.apache.nifi.processors.standard.TestPutSyslog: java.net.InetAddress address> = v;
v = new org.apache.nifi.event.transport.netty.ByteArrayMessageNettyEventServerFactory;
v = new org.apache.nifi.mock.MockComponentLogger;
specialinvoke v.<org.apache.nifi.mock.MockComponentLogger: void <init>()>();
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: java.net.InetAddress address>;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.configuration.TransportProtocol protocol>;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: java.util.concurrent.BlockingQueue messages>;
specialinvoke v.<org.apache.nifi.event.transport.netty.ByteArrayMessageNettyEventServerFactory: void <init>(org.apache.nifi.logging.ComponentLog,java.net.InetAddress,int,org.apache.nifi.event.transport.configuration.TransportProtocol,byte[],int,java.util.concurrent.BlockingQueue)>(v, v, 0, v, v, 1024, v);
v = <org.apache.nifi.event.transport.configuration.ShutdownQuietPeriod: org.apache.nifi.event.transport.configuration.ShutdownQuietPeriod QUICK>;
v = virtualinvoke v.<org.apache.nifi.event.transport.configuration.ShutdownQuietPeriod: java.time.Duration getDuration()>();
virtualinvoke v.<org.apache.nifi.event.transport.netty.NettyEventServerFactory: void setShutdownQuietPeriod(java.time.Duration)>(v);
v = <org.apache.nifi.event.transport.configuration.ShutdownTimeout: org.apache.nifi.event.transport.configuration.ShutdownTimeout QUICK>;
v = virtualinvoke v.<org.apache.nifi.event.transport.configuration.ShutdownTimeout: java.time.Duration getDuration()>();
virtualinvoke v.<org.apache.nifi.event.transport.netty.NettyEventServerFactory: void setShutdownTimeout(java.time.Duration)>(v);
v = virtualinvoke v.<org.apache.nifi.event.transport.netty.NettyEventServerFactory: org.apache.nifi.event.transport.EventServer getEventServer()>();
v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer> = v;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer>;
v = interfaceinvoke v.<org.apache.nifi.event.transport.EventServer: int getListeningPort()>();
v.<org.apache.nifi.processors.standard.TestPutSyslog: int port> = v;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/PutSyslog;");
v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner> = v;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor HOSTNAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "127.0.0.1");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor PROTOCOL>;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.configuration.TransportProtocol protocol>;
v = virtualinvoke v.<org.apache.nifi.event.transport.configuration.TransportProtocol: java.lang.String toString()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor PORT>;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: int port>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_BODY>;
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String MESSAGE_BODY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_PRIORITY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_HOSTNAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "localhost");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_TIMESTAMP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Jan 1 00:00:00");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
return;
}
public void shutdownEventServer()
{
org.apache.nifi.event.transport.EventServer v, v;
org.apache.nifi.processors.standard.TestPutSyslog v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer>;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer>;
interfaceinvoke v.<org.apache.nifi.event.transport.EventServer: void shutdown()>();
label:
return;
}
public void testRunNoFlowFiles()
{
org.apache.nifi.util.TestRunner v, v;
org.apache.nifi.processors.standard.TestPutSyslog v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueEmpty()>();
return;
}
public void testRunSuccess() throws java.lang.InterruptedException
{
java.lang.String v;
org.apache.nifi.processors.standard.TestPutSyslog v;
java.util.Map v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String SYSLOG_MESSAGE>;
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSyslog: void assertSyslogMessageSuccess(java.lang.String,java.util.Map)>(v, v);
return;
}
public void testRunSuccessSyslogVersion() throws java.lang.InterruptedException
{
java.lang.Object[] v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestPutSyslog v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_VERSION>;
v = newarray (java.lang.Object)[1];
v[0] = "version";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("${%s}", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("version", "2");
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String VERSION_SYSLOG_MESSAGE>;
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSyslog: void assertSyslogMessageSuccess(java.lang.String,java.util.Map)>(v, v);
return;
}
public void testRunInvalid()
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
org.apache.nifi.processors.standard.TestPutSyslog v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor MSG_PRIORITY>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(2147483647);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = newarray (byte)[0];
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.processor.Relationship REL_INVALID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship)>(v);
return;
}
public void testRunFailure()
{
byte[] v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestPutSyslog v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor PROTOCOL>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.AllowableValue TCP_VALUE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor HOSTNAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "this-host-does-not-exist");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "44");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = newarray (byte)[0];
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship)>(v);
return;
}
private void assertSyslogMessageSuccess(java.lang.String, java.util.Map) throws java.lang.InterruptedException
{
java.lang.Throwable v;
byte[] v;
java.nio.charset.Charset v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
org.apache.nifi.processors.standard.TestPutSyslog v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.event.transport.EventServer v, v;
java.util.concurrent.BlockingQueue v;
java.util.concurrent.TimeUnit v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
label:
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: java.util.concurrent.BlockingQueue messages>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(5L, v);
v = new java.lang.String;
v = virtualinvoke v.<org.apache.nifi.event.transport.message.ByteArrayMessage: byte[] getMessage()>();
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.nio.charset.Charset CHARSET>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSyslog: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSyslog: void assertProvenanceRecordTransitUriFound()>();
label:
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer>;
interfaceinvoke v.<org.apache.nifi.event.transport.EventServer: void shutdown()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.event.transport.EventServer eventServer>;
interfaceinvoke v.<org.apache.nifi.event.transport.EventServer: void shutdown()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void assertProvenanceRecordTransitUriFound()
{
java.util.Iterator v;
org.apache.nifi.provenance.ProvenanceEventType v, v;
java.util.List v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestPutSyslog v;
int v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestPutSyslog;
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "Provenance Events not found");
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.nifi.provenance.ProvenanceEventType: org.apache.nifi.provenance.ProvenanceEventType SEND>;
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: org.apache.nifi.provenance.ProvenanceEventType getEventType()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: java.lang.String getTransitUri()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object,java.lang.String)>(v, "Transit URI not found");
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("UDP");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Transit URI Protocol not found");
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("127.0.0.1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Transit URI Hostname not found");
v = v.<org.apache.nifi.processors.standard.TestPutSyslog: int port>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Transit URI Port not found");
return;
}
static void <clinit>()
{
java.lang.Object[] v, v;
java.nio.charset.Charset v;
java.lang.Class v;
java.lang.String v, v, v, v, v;
v = class "Ljava/lang/String;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
<org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String MESSAGE_BODY> = v;
v = newarray (java.lang.Object)[4];
v[0] = "1";
v[1] = "Jan 1 00:00:00";
v[2] = "localhost";
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String MESSAGE_BODY>;
v[3] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("<%s>%s %s %s", v);
<org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String SYSLOG_MESSAGE> = v;
v = newarray (java.lang.Object)[5];
v[0] = "1";
v[1] = "2";
v[2] = "Jan 1 00:00:00";
v[3] = "localhost";
v = <org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String MESSAGE_BODY>;
v[4] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("<%s>%s %s %s %s", v);
<org.apache.nifi.processors.standard.TestPutSyslog: java.lang.String VERSION_SYSLOG_MESSAGE> = v;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
<org.apache.nifi.processors.standard.TestPutSyslog: java.nio.charset.Charset CHARSET> = v;
return;
}
}