public class org.apache.nifi.processors.standard.util.JmsProperties extends java.lang.Object { public static final java.lang.String ACTIVEMQ_PROVIDER; public static final java.lang.String ACK_MODE_CLIENT; public static final java.lang.String ACK_MODE_AUTO; public static final java.lang.String DESTINATION_TYPE_QUEUE; public static final java.lang.String DESTINATION_TYPE_TOPIC; public static final java.lang.String MSG_TYPE_BYTE; public static final java.lang.String MSG_TYPE_TEXT; public static final java.lang.String MSG_TYPE_STREAM; public static final java.lang.String MSG_TYPE_MAP; public static final java.lang.String MSG_TYPE_EMPTY; public static final org.apache.nifi.components.PropertyDescriptor JMS_PROVIDER; public static final org.apache.nifi.components.PropertyDescriptor URL; public static final org.apache.nifi.components.PropertyDescriptor TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor USERNAME; public static final org.apache.nifi.components.PropertyDescriptor PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor CLIENT_ID_PREFIX; public static final org.apache.nifi.components.PropertyDescriptor DESTINATION_NAME; public static final org.apache.nifi.components.PropertyDescriptor DESTINATION_TYPE; public static final org.apache.nifi.components.PropertyDescriptor DURABLE_SUBSCRIPTION; public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_TO_JMS_PROPS; public static final org.apache.nifi.components.PropertyDescriptor BATCH_SIZE; public static final org.apache.nifi.components.PropertyDescriptor ACKNOWLEDGEMENT_MODE; public static final org.apache.nifi.components.PropertyDescriptor JMS_PROPS_TO_ATTRIBUTES; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE_SELECTOR; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE_TYPE; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE_PRIORITY; public static final org.apache.nifi.components.PropertyDescriptor REPLY_TO_QUEUE; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE_TTL; public static final org.apache.nifi.components.PropertyDescriptor MAX_BUFFER_SIZE; public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE; public void () { org.apache.nifi.processors.standard.util.JmsProperties v; v := @this: org.apache.nifi.processors.standard.util.JmsProperties; specialinvoke v.()>(); return; } static void () { org.apache.nifi.expression.ExpressionLanguageScope v, v; 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; org.apache.nifi.components.PropertyDescriptor$Builder 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, 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, 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, v, v, v, v, v, v, v, v, 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; org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v, v, v, v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("JMS Provider"); v = virtualinvoke v.("The Provider used for the JMS Server"); v = virtualinvoke v.(1); v = newarray (java.lang.String)[1]; v[0] = "ActiveMQ"; v = virtualinvoke v.(v); v = virtualinvoke v.("ActiveMQ"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("URL"); v = virtualinvoke v.("The URL of the JMS Server"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Communications Timeout"); v = virtualinvoke v.("The amount of time to wait when attempting to receive a message before giving up and assuming failure"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("30 sec"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Username"); v = virtualinvoke v.("Username used for authentication and authorization"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Password"); v = virtualinvoke v.("Password used for authentication and authorization"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Client ID Prefix"); v = virtualinvoke v.("A human-readable ID that can be used to associate connections with yourself so that the maintainers of the JMS Server know who to contact if problems arise"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Destination Name"); v = virtualinvoke v.("The name of the JMS Topic or queue to use"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Destination Type"); v = virtualinvoke v.("The type of the JMS Destination to use"); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "Queue"; v[1] = "Topic"; v = virtualinvoke v.(v); v = virtualinvoke v.("Queue"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Use Durable Subscription"); v = virtualinvoke v.("If true, connections to the specified topic will use Durable Subscription so that messages are queued when we are not pulling them"); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("false"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Copy Attributes to JMS Properties"); v = virtualinvoke v.("Whether or not FlowFile Attributes should be translated into JMS Message Properties. If true, all attributes starting with \'jms.\' will be set as Properties on the JMS Message (without the \'jms.\' prefix). If an attribute exists that starts with the same value but ends in \'.type\', that attribute will be used to determine the JMS Message Property type."); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("true"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Message Batch Size"); v = virtualinvoke v.("The number of messages to pull/push in a single iteration of the processor"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("10"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Acknowledgement Mode"); v = virtualinvoke v.("The JMS Acknowledgement Mode. Using Auto Acknowledge can cause messages to be lost on restart of NiFi but may provide better performance than Client Acknowledge."); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "Client Acknowledge"; v[1] = "Auto Acknowledge"; v = virtualinvoke v.(v); v = virtualinvoke v.("Client Acknowledge"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Copy JMS Properties to Attributes"); v = virtualinvoke v.("Whether or not the JMS Message Properties should be copied to the FlowFile Attributes; if so, the attribute name will be jms.XXX, where XXX is the JMS Property name"); v = virtualinvoke v.(1); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.("true"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Message Selector"); v = virtualinvoke v.("The JMS Message Selector to use in order to narrow the messages that are pulled"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Message Type"); v = virtualinvoke v.("The Type of JMS Message to Construct"); v = virtualinvoke v.(1); v = newarray (java.lang.String)[5]; v[0] = "byte"; v[1] = "stream"; v[2] = "text"; v[3] = "map"; v[4] = "empty"; v = virtualinvoke v.(v); v = virtualinvoke v.("byte"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Message Priority"); v = virtualinvoke v.("The Priority of the Message"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Reply-To Queue"); v = virtualinvoke v.("The name of the queue to which a reply to should be added"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Message Time to Live"); v = virtualinvoke v.("The amount of time that the message should live on the destination before being removed; if not specified, the message will never expire."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Max Buffer Size"); v = virtualinvoke v.("The maximum amount of data that can be buffered for a JMS Message. If a FlowFile\'s size exceeds this value, the FlowFile will be routed to failure."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("1 MB"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SSL Context Service"); v = virtualinvoke v.("The Controller Service to use in order to obtain an SSL Context."); v = virtualinvoke v.(0); v = virtualinvoke v.(class "Lorg/apache/nifi/ssl/SSLContextService;"); v = virtualinvoke v.(); = v; return; } }