public class org.apache.nifi.processors.standard.TestPutJMS extends java.lang.Object { private final java.lang.String TEST_PROVIDER; private final java.lang.String TEST_URL; private final java.lang.String TEST_DEST_TYPE; private final java.lang.String TEST_DEST_NAME; private final java.lang.String TEST_ACK_MODE; public void () { org.apache.nifi.processors.standard.TestPutJMS v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; specialinvoke v.()>(); v. = "ActiveMQ"; v. = "vm://localhost?broker.persistent=false"; v. = "Queue"; v. = "queue.testing"; v. = "Auto Acknowledge"; return; } private java.lang.String testQueueSuffix() { java.lang.StackTraceElement[] v; java.lang.Thread v; org.apache.nifi.processors.standard.TestPutJMS v; java.lang.StackTraceElement v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = staticinvoke (); v = virtualinvoke v.(); v = v[2]; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) (".\u0001"); return v; } private void injectFieldValue(java.lang.Class, java.lang.Object, java.lang.String, java.lang.Object) throws java.lang.NoSuchFieldException, java.lang.IllegalAccessException { org.apache.nifi.processors.standard.TestPutJMS v; java.lang.Class v; java.lang.Object v, v; java.lang.String v; java.lang.reflect.Field v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v := @parameter: java.lang.Class; v := @parameter: java.lang.Object; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v = virtualinvoke v.(v); virtualinvoke v.(1); virtualinvoke v.(v, v); return; } public void testGetRelationships() { org.apache.nifi.processors.standard.PutJMS v; java.util.Set v; org.apache.nifi.processor.Relationship v, v; int v; org.apache.nifi.processors.standard.TestPutJMS v; boolean v, v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (2, v); v = ; v = interfaceinvoke v.(v); staticinvoke (v); v = ; v = interfaceinvoke v.(v); staticinvoke (v); return; } public void testCleanupResources() throws javax.jms.JMSException, java.lang.NoSuchFieldException, java.lang.IllegalAccessException { org.apache.nifi.processors.standard.PutJMS v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processors.standard.util.WrappedMessageProducer v; java.util.concurrent.LinkedBlockingQueue v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestPutJMS v; java.lang.Object v, v, v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v = staticinvoke (v); specialinvoke v.(class "Lorg/apache/nifi/processors/standard/PutJMS;", v, "producerQueue", v); v = interfaceinvoke v.(); v = staticinvoke (v, 1); interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (v); virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v); return; } public void testCreateMessageDirectly() throws javax.jms.JMSException { org.apache.nifi.processors.standard.PutJMS v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; javax.jms.Session v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v; int v; org.apache.nifi.processors.standard.TestPutJMS v; java.lang.String v, v, v, v, v, v; javax.jms.MessageProducer v; org.apache.nifi.processors.standard.GetJMSQueue v; javax.jms.TextMessage v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processors.standard.util.WrappedMessageProducer v; org.apache.nifi.processor.Relationship$Builder v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Auto Acknowledge"); v = interfaceinvoke v.(); v = staticinvoke (v, 1); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("createMessageDirectly"); interfaceinvoke v.(v); interfaceinvoke v.(); v = new org.apache.nifi.processors.standard.GetJMSQueue; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Auto Acknowledge"); interfaceinvoke v.(); v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("success"); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.("createMessageDirectly"); v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); virtualinvoke v.("jms.JMSDestination", v); interfaceinvoke v.(); interfaceinvoke v.(); return; } public void testPutGetAttributesAndProps() { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v; java.util.List v, v, v, v; org.apache.nifi.processors.standard.PutJMS v, v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v, v, v; int v, v, v, v; org.apache.nifi.processors.standard.TestPutJMS v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.GetJMSQueue v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u.reply"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "true"); interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("jms.string", "banana"); interfaceinvoke v.("jms.integer", "50"); interfaceinvoke v.("jms.integer.type", "integer"); interfaceinvoke v.("jms.float", "3.14159"); interfaceinvoke v.("jms.float.type", "float"); interfaceinvoke v.("jms.boolean", "true"); interfaceinvoke v.("jms.boolean.type", "boolean"); interfaceinvoke v.("jms.long", "123456789"); interfaceinvoke v.("jms.long.type", "long"); interfaceinvoke v.("jms.short", "16384"); interfaceinvoke v.("jms.short.type", "short"); interfaceinvoke v.("jms.byte", "127"); interfaceinvoke v.("jms.byte.type", "byte"); interfaceinvoke v.("jms.double", "3.1415626547"); interfaceinvoke v.("jms.double.type", "double"); interfaceinvoke v.("jms.object", "{\"id\":215, \"name\": \"john doe\"}"); interfaceinvoke v.("jms.object.type", "object"); interfaceinvoke v.("jms.eyes", "blue"); interfaceinvoke v.("jms.eyes.type", "color"); interfaceinvoke v.("jms.badinteger", "3.14"); interfaceinvoke v.("jms.badinteger.type", "integer"); v = "putGetMessage"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = new org.apache.nifi.processors.standard.GetJMSQueue; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Auto Acknowledge"); v = ; interfaceinvoke v.(v, "true"); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.("putGetMessage"); v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); virtualinvoke v.("jms.JMSDestination", v); v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue://queue.testing\u.reply"); virtualinvoke v.("jms.JMSReplyTo", v); virtualinvoke v.("jms.string", "banana"); virtualinvoke v.("jms.integer", "50"); virtualinvoke v.("jms.float", "3.14159"); virtualinvoke v.("jms.boolean", "true"); virtualinvoke v.("jms.long", "123456789"); virtualinvoke v.("jms.short", "16384"); virtualinvoke v.("jms.byte", "127"); virtualinvoke v.("jms.double", "3.1415626547"); virtualinvoke v.("jms.object", "{\"id\":215, \"name\": \"john doe\"}"); virtualinvoke v.("jms.eyes", null); virtualinvoke v.("jms.badinteger", null); return; } public void testPutGetMessageTypes() { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.PutJMS v, v, v, v, v, v, v, v, v, v; java.util.HashMap v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestPutJMS v; org.apache.nifi.processors.standard.GetJMSQueue v; java.lang.Object v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.GetJMSQueue; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Auto Acknowledge"); v = ; interfaceinvoke v.(v, "true"); v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "text"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("putGetTextMessage", v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.("putGetTextMessage"); v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "empty"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("putGetEmptyMessage", v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.(""); v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "stream"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("putGetStreamMessage", v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.("putGetStreamMessage"); v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "map"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("putGetMapMessage", v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.(""); v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.(v, "vm://localhost?broker.persistent=false"); v = ; interfaceinvoke v.(v, "Queue"); v = ; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("queue.testing\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "byte"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "file.txt"); interfaceinvoke v.("putGetTextMessage", v); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (0, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(); interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1, v); v = interfaceinvoke v.(0); virtualinvoke v.("putGetTextMessage"); return; } public void testTTL() throws java.lang.InterruptedException { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v; java.util.List v, v, v, v, v, v; org.apache.nifi.processors.standard.PutJMS v, v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; int v, v, v, v, v, v; org.apache.nifi.processors.standard.TestPutJMS v; java.lang.String v, v, v, v, v, v; org.apache.nifi.processors.standard.GetJMSQueue v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestPutJMS; v = new org.apache.nifi.processors.standard.PutJMS; specialinvoke v.()>(); staticinvoke (v); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "ActiveMQ"); v = ; interfaceinvoke v.