I see getting customized processors is a bit more involved as described here: https://community.hortonworks.com/articles/4318/build-custom-nifi-processor.html ... View more

Thank you for the quick response. I'm needing to go the roll my own route, since the I get an error that "targetClient" is not allowed for 'XMSC_DESTINATION_NAME'. When setting up a processor that uses custom java code what script engine to you specify assuming you are using on of the script processors? Also, to you know how to inject the flowfile stream contents into the java code, since I need that instead of the line ""Hello MQSTR world via MQQueue"? import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session; import javax.jms.TextMessage; import com.ibm.mq.jms.MQQueue; import com.ibm.mq.jms.MQQueueConnectionFactory; import com.ibm.msg.client.wmq.compat.jms.internal.JMSC; public void testMqstrViaApiTextMessage() throws Exception { QueueConnectionFactory connectionFactory = new MQQueueConnectionFactory(); ((MQQueueConnectionFactory) connectionFactory).setHostName("mfdevlcics.mayo.edu"); ((MQQueueConnectionFactory) connectionFactory).setPort(3667); ((MQQueueConnectionFactory) connectionFactory).setChannel("MCF.EDT.Q10I.01"); ((MQQueueConnectionFactory) connectionFactory).setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP); QueueConnection connection = connectionFactory.createQueueConnection(); connection.start(); QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = session.createQueue("IMA.EDT.NL.007"); // Force MQSTR format ((MQQueue) queue).setTargetClient(JMSC.MQJMS_CLIENT_NONJMS_MQ); QueueSender messageProducer = session.createSender(queue); TextMessage textMessage = session.createTextMessage("Hello MQSTR world via MQQueue"); messageProducer.send(textMessage); session.close(); connection.close(); } ... View more

For those who may be at a back level HDF version as we are a good workaround is to use the SplitContent instead as it utilizes many of the attributes Matt has documented above for the SplitJson processor. ... View more

@Matt Burgess You are correct about my being back level for this support. Can anyone suggest a workaround, such as another processor attribute that could do something similar? ... View more

Ah, I see we're at NiFi version 0.5.1.1.1.2.1-34, so that explains why I am not seeing these attributes. ... View more

Thanks for the prompt reply. I've also tried to address this question in item: https://community.hortonworks.com/questions/68745/nifi-iteration-of-queue-entries-between-processors.html I'm trying to get similar behavior as can be seen below for 'executesql.row.count' by using a user-defined property (property - iteration : value - ${'fragment.index'} <with and without single quote, set prior to 'SplitJson' or set post 'SplitJson') I'm only able to get 'No value set' or 'Empty value set' no matter what I try. The splitjson is very straight forward and successfully builds many json array objects using the expression below. All I'm attempting to due is keep track of the queue position, so I can act on the last row to post the last transaction date. The attribute 'queue position' would also be of interest, but it also contains no data. Thanks, ~Sean ... View more