Member since
01-18-2017
58
Posts
5
Kudos Received
0
Solutions
02-21-2017
03:35 PM
I need help to Setup MQ for Nifi. I have a very tight deadline for a project to retrieve data from IBM MQ to Nifi. I installed IBM MQ on my local computer. I was able to configure the queues to read one from another. but I have issue on setup configurations for Nifi. Any advice on the MQ configuration for Nifi will be very appreciated.
... View more
Labels:
- Labels:
-
Apache NiFi
02-21-2017
03:21 PM
@ozhurakousky Thank you very much for spending time to helping me. Do you have any information on how to setup IBM mq for Nifi? e.g. how could I set up the SYSTEM.ADMIN.SVRCONN for channel or is it build-in already? Do I need to create a transmission queue for the channel?
... View more
02-21-2017
04:45 AM
Hi Sharath, I have some issue connecting Nifi to IBM MQ. To setup the IBM MQ, I follow the instruction at https://www.ibm.com/support/knowledgecenter/SSFKSJ_9.0.0/com.ibm.mq.sce.doc/q123070_.htm. Unfortunately, it have issue for the connections. Do you mind to tell me how you configure the setttngs on the IBM MQ server side? Do you need to create a transmission queue and how do you create your Channel? Thanks a lot Andy
... View more
02-20-2017
04:50 PM
@ozhurakousky Thank you very much for your help, I am fine tuning the settings and keep testing. It's in the right direction now, although I still have other issues.
... View more
02-20-2017
04:03 PM
@ozhurakousky For the confiugration of IBM MQ, I followed the instruction at https://www.ibm.com/support/knowledgecenter/SSFKSJ_9.0.0/com.ibm.mq.sce.doc/q123070_.htm It should should have configured the parameters of the Nifi, The only parameter that it skips is the channel. any other configuration that I missed?
... View more
02-20-2017
02:50 PM
@ozhurakousky Thank you very much for your advice. It's very helpful for me. After I modified the connection factory to com.ibm.mq.jms.MQQueueConnectionFactory and set the Destination Name to queue://NifiMQ/Q1, I didn't see the controller-services issue. I got another error: 2017-02-20 09:33:28,807 WARN [Timer-Driven Process Thread-8] o.a.n.c.t.ContinuallyRunProcessorTask
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is com.ibm.msg.client.jms.DetailedJMSException: JMSFMQ6312: An exception occurred in the Java(tm) MQI.
The Java(tm) MQI has thrown an exception describing the problem.
See the linked exception for further information.; nested exception is com.ibm.mq.jmqi.JmqiException: CC=2;RC=2495;AMQ8568: The native JNI library 'mqjbnd64' was not found. For a client installation this is expected. [3=mqjbnd64] For development, I installed IBM MQ locally on my computer, and set the MQ Client Libraries path to C:/Program Files/IBM/WebSphere MQ/java/lib
... View more
02-20-2017
10:48 AM
When I use Nifi connect to IBM MQ, nifi disabled controller-services and ConsumeJMS failed. I got the following error: ConsumeJMS - null ConsumeJMS - null failed to process session due to java.lang.IllegalStateException: Cannot invoke method public abstract javax.jms.ConnectionFactory org.apache.nifi.jms.cf.JMSConnectionFactoryProviderDefinition.getConnectionFactory() on Controller Service with identifier 57fa0ec2-015a-1000-1377-c1374f9dd1c1 because the Controller Service is disabled: java.lang.IllegalStateException: Cannot invoke method public abstract javax.jms.ConnectionFactory org.apache.nifi.jms.cf.JMSConnectionFactoryProviderDefinition.getConnectionFactory() on Controller Service with identifier 57fa0ec2-015a-1000-1377-c1374f9dd1c1 because the Controller Service is disabled nifi Error log: 2017-02-20 05:32:21,023 ERROR [Timer-Driven Process Thread-5] o.apache.nifi.jms.processors.ConsumeJMS ConsumeJMS - null ConsumeJMS - null failed to process session due to java.lang.IllegalStateException: Cannot invoke method public abstract javax.jms.ConnectionFactory org.apache.nifi.jms.cf.JMSConnectionFactoryProviderDefinition.getConnectionFactory() on Controller Service with identifier 57fa0ec2-015a-1000-1377-c1374f9dd1c1 because the Controller Service is disabled: java.lang.IllegalStateException: Cannot invoke method public abstract javax.jms.ConnectionFactory org.apache.nifi.jms.cf.JMSConnectionFactoryProviderDefinition.getConnectionFactory() on Controller Service with identifier 57fa0ec2-015a-1000-1377-c1374f9dd1c1 because the Controller Service is disabled
2017-02-20 05:32:21,025 ERROR [Timer-Driven Process Thread-5] o.apache.nifi.jms.processors.ConsumeJMS
java.lang.IllegalStateException: Cannot invoke method public abstract javax.jms.ConnectionFactory org.apache.nifi.jms.cf.JMSConnectionFactoryProviderDefinition.getConnectionFactory() on Controller Service with identifier 57fa0ec2-015a-1000-1377-c1374f9dd1c1 because the Controller Service is disabled
at org.apache.nifi.controller.service.StandardControllerServiceProvider$1.invoke(StandardControllerServiceProvider.java:172) ~[nifi-framework-core-1.1.1.jar:1.1.1]
at com.sun.proxy.$Proxy139.getConnectionFactory(Unknown Source) ~[na:na]
at org.apache.nifi.jms.processors.AbstractJMSProcessor.buildTargetResource(AbstractJMSProcessor.java:190) ~[na:na]
at org.apache.nifi.jms.processors.AbstractJMSProcessor.onTrigger(AbstractJMSProcessor.java:134) ~[na:na]
at org.apache.nifi.jms.processors.ConsumeJMS.onTrigger(ConsumeJMS.java:57) ~[na:na]
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) ~[nifi-api-1.1.1.jar:1.1.1]
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1099) ~[nifi-framework-core-1.1.1.jar:1.1.1]
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136) [nifi-framework-core-1.1.1.jar:1.1.1]
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) [nifi-framework-core-1.1.1.jar:1.1.1]
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132) [nifi-framework-core-1.1.1.jar:1.1.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_111]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_111]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_111]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_111]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_111]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_111]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_111] JMSConnectionFactoryProvider settings: ConsumeJMS settings Any suggestion on how to solve this issue is appreciated. Thanks a lot Andy
... View more
Labels:
- Labels:
-
Apache NiFi
02-16-2017
01:55 PM
Sorry for asking a silly questions: Does Nifi use One-way or two-way SSL authentication? Thanks Andy
... View more
Labels:
- Labels:
-
Apache NiFi
02-09-2017
10:25 PM
@Pierre Villard Thank you very much for the information. and I also learned a lot from your Nifi templates on github.
... View more
02-08-2017
12:02 AM
Hi, I am working on a project which is using the HandleHttpRequest processor and we need the client Authentication. After we set the Client Authentication of HandleHttpRequest processor to "Need Authentication", what other configuration is need? According to the document, This value is ignored if the <SSL Context Service> Property is not specified or the SSL Context provided uses only a KeyStore and not a TrustStore. Any detail information or example is available? Thanks a lot Andy
... View more
Labels:
- Labels:
-
Apache NiFi
- « Previous
- Next »