public class org.apache.nifi.processors.standard.PutJMS extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.nio.charset.Charset UTF8;
public static final int DEFAULT_MESSAGE_PRIORITY;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private final java.util.Queue producerQueue;
private final java.util.List properties;
private final java.util.Set relationships;
public void <init>()
{
org.apache.nifi.processors.standard.PutJMS v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v;
java.util.Set v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor JMS_PROVIDER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor URL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor DESTINATION_NAME>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor DESTINATION_TYPE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor TIMEOUT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor USERNAME>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_TYPE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_PRIORITY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor REPLY_TO_QUEUE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_TTL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_JMS_PROPS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor CLIENT_ID_PREFIX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.PutJMS: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.PutJMS: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.processors.standard.PutJMS v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.PutJMS v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Set relationships>;
return v;
}
public void cleanupResources()
{
org.apache.nifi.processors.standard.PutJMS v;
java.lang.Object v;
java.util.Queue v, v;
org.apache.nifi.logging.ComponentLog v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.logging.ComponentLog getLogger()>();
virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: void close(org.apache.nifi.logging.ComponentLog)>(v);
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
goto label;
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
byte[] v;
java.lang.Integer v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v;
javax.jms.Session v;
byte v;
java.lang.Long v;
org.apache.nifi.processor.DataUnit v;
java.lang.Throwable v, v, v, v, v;
java.lang.Object[] v, v, v, v, v, v, v, v;
java.lang.Double v;
long v, v, v;
org.apache.nifi.provenance.ProvenanceReporter v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
java.lang.String v, v, v, v, v;
javax.jms.Message v;
java.lang.NumberFormatException v;
org.apache.nifi.processor.ProcessSession v;
javax.jms.Queue v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v;
javax.jms.MessageProducer v;
boolean v, v, v, v, v;
org.apache.nifi.processors.standard.PutJMS$1 v;
java.util.List v;
java.util.Queue v, v, v, v;
org.apache.nifi.processors.standard.PutJMS v;
org.apache.nifi.logging.ComponentLog v;
java.util.HashSet v;
int v, v, v, v, v, v;
java.util.Iterator v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.util.List get(int)>(v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v != null goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.JmsFactory: org.apache.nifi.processors.standard.util.WrappedMessageProducer createMessageProducer(org.apache.nifi.processor.ProcessContext,boolean)>(v, 1);
v = newarray (java.lang.Object)[1];
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor URL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Connected to JMS server {}", v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to connect to JMS Server due to {}", v);
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: javax.jms.Session getSession()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: javax.jms.MessageProducer getProducer()>();
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = virtualinvoke v.<java.lang.Double: int intValue()>();
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v cmp v;
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Routing {} to failure because its size exceeds the configured max", v);
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = newarray (byte)[v];
v = new org.apache.nifi.processors.standard.PutJMS$1;
specialinvoke v.<org.apache.nifi.processors.standard.PutJMS$1: void <init>(org.apache.nifi.processors.standard.PutJMS,byte[])>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_TTL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor REPLY_TO_QUEUE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.JmsFactory: javax.jms.Queue createQueue(org.apache.nifi.processor.ProcessContext,java.lang.String)>(v, v);
label:
v = v;
v = 4;
label:
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_PRIORITY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
if v != null goto label;
v = 4;
goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = v;
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_PRIORITY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Invalid value for JMS Message Priority: {}; defaulting to priority of {}", v);
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.PutJMS: javax.jms.Message createMessage(javax.jms.Session,org.apache.nifi.processor.ProcessContext,byte[],org.apache.nifi.flowfile.FlowFile,javax.jms.Destination,java.lang.Integer)>(v, v, v, v, v, v);
if v != null goto label;
interfaceinvoke v.<javax.jms.MessageProducer: void setTimeToLive(long)>(0L);
goto label;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
interfaceinvoke v.<javax.jms.MessageProducer: void setTimeToLive(long)>(v);
label:
interfaceinvoke v.<javax.jms.MessageProducer: void send(javax.jms.Message)>(v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to send {} to JMS Server due to {}", v);
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
label:
interfaceinvoke v.<javax.jms.Session: void rollback()>();
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Unable to roll back JMS Session due to {}", v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: void close(org.apache.nifi.logging.ComponentLog)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
interfaceinvoke v.<java.util.Queue: boolean offer(java.lang.Object)>(v);
label:
return;
label:
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor URL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void send(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(v, v);
goto label;
label:
interfaceinvoke v.<javax.jms.Session: void commit()>();
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<java.util.Set: int size()>();
if v <= 10 goto label;
v = interfaceinvoke v.<java.util.Set: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u FlowFiles");
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Sent {} to JMS Server and transferred to \'success\'", v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to commit JMS Session due to {} and transferred to \'failure\'", v);
v = <org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: void close(org.apache.nifi.logging.ComponentLog)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
interfaceinvoke v.<java.util.Queue: boolean offer(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.WrappedMessageProducer: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.PutJMS: java.util.Queue producerQueue>;
interfaceinvoke v.<java.util.Queue: boolean offer(java.lang.Object)>(v);
label:
throw v;
label:
return;
catch javax.jms.JMSException from label to label with label;
catch java.lang.NumberFormatException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private javax.jms.Message createMessage(javax.jms.Session, org.apache.nifi.processor.ProcessContext, byte[], org.apache.nifi.flowfile.FlowFile, javax.jms.Destination, java.lang.Integer) throws javax.jms.JMSException
{
byte[] v;
org.apache.nifi.processors.standard.PutJMS v;
long v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.components.PropertyValue v, v;
javax.jms.Session v;
byte v;
java.nio.charset.Charset v;
int v, v;
java.lang.Boolean v;
java.lang.String v, v;
boolean v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
javax.jms.StreamMessage v;
org.apache.nifi.processor.ProcessContext v;
javax.jms.BytesMessage v;
javax.jms.Destination v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v := @parameter: javax.jms.Session;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: byte[];
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.Integer;
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor MESSAGE_TYPE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -891990144: goto label;
case 107868: goto label;
case 3039496: goto label;
case 3556653: goto label;
case 96634189: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("empty");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("stream");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("text");
if v == 0 goto label;
v = 2;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("map");
if v == 0 goto label;
v = 3;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("byte");
if v == 0 goto label;
v = 4;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage(java.lang.String)>("");
goto label;
label:
v = interfaceinvoke v.<javax.jms.Session: javax.jms.StreamMessage createStreamMessage()>();
interfaceinvoke v.<javax.jms.StreamMessage: void writeBytes(byte[])>(v);
v = v;
goto label;
label:
v = new java.lang.String;
v = <org.apache.nifi.processors.standard.PutJMS: java.nio.charset.Charset UTF8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage(java.lang.String)>(v);
goto label;
label:
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MapMessage createMapMessage()>();
goto label;
label:
v = interfaceinvoke v.<javax.jms.Session: javax.jms.BytesMessage createBytesMessage()>();
interfaceinvoke v.<javax.jms.BytesMessage: void writeBytes(byte[])>(v);
v = v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
interfaceinvoke v.<javax.jms.Message: void setJMSTimestamp(long)>(v);
if v == null goto label;
interfaceinvoke v.<javax.jms.Message: void setJMSReplyTo(javax.jms.Destination)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<javax.jms.Message: void setJMSPriority(int)>(v);
label:
v = <org.apache.nifi.processors.standard.util.JmsProperties: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_JMS_PROPS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.PutJMS: void copyAttributesToJmsProps(org.apache.nifi.flowfile.FlowFile,javax.jms.Message)>(v, v);
label:
return v;
}
private void copyAttributesToJmsProps(org.apache.nifi.flowfile.FlowFile, javax.jms.Message) throws javax.jms.JMSException
{
byte v;
java.util.Map v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
java.util.Set v;
float v;
org.apache.nifi.processors.standard.PutJMS v;
java.lang.Object[] v, v;
long v;
org.apache.nifi.logging.ComponentLog v;
short v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
javax.jms.Message v;
double v;
java.util.Iterator v;
java.lang.NumberFormatException v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.PutJMS;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: javax.jms.Message;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = "jms.";
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = ".type";
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(v);
if v != 0 goto label;
v = "jms.";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.type");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("string");
if v == 0 goto label;
label:
interfaceinvoke v.<javax.jms.Message: void setStringProperty(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("integer");
if v == 0 goto label;
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setIntProperty(java.lang.String,int)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("boolean");
if v == 0 goto label;
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setBooleanProperty(java.lang.String,boolean)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("short");
if v == 0 goto label;
v = staticinvoke <java.lang.Short: short parseShort(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setShortProperty(java.lang.String,short)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("long");
if v == 0 goto label;
v = staticinvoke <java.lang.Long: long parseLong(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setLongProperty(java.lang.String,long)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("byte");
if v == 0 goto label;
v = staticinvoke <java.lang.Byte: byte parseByte(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setByteProperty(java.lang.String,byte)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("double");
if v == 0 goto label;
v = staticinvoke <java.lang.Double: double parseDouble(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setDoubleProperty(java.lang.String,double)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("float");
if v == 0 goto label;
v = staticinvoke <java.lang.Float: float parseFloat(java.lang.String)>(v);
interfaceinvoke v.<javax.jms.Message: void setFloatProperty(java.lang.String,float)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("object");
if v == 0 goto label;
interfaceinvoke v.<javax.jms.Message: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Attribute key \'{}\' for {} has value \'{}\', but expected one of: integer, string, object, byte, double, float, long, short, boolean; not adding this property", v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[5];
v[0] = v;
v[1] = v;
v[2] = v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.type");
v[3] = v;
v[4] = "integer";
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Attribute key \'{}\' for {} has value \'{}\', but attribute key \'{}\' has value \'{}\'. Not adding this JMS property", v);
goto label;
label:
return;
catch java.lang.NumberFormatException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
java.nio.charset.Charset v;
org.apache.nifi.processor.Relationship v, v;
v = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset forName(java.lang.String)>("UTF-8");
<org.apache.nifi.processors.standard.PutJMS: java.nio.charset.Charset UTF8> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("All FlowFiles that are sent to the JMS destination are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("All FlowFiles that cannot be routed to the JMS destination are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.PutJMS: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}