Created 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.
Created 02-21-2017 03:44 PM
The ConsumeJMS and PublishJMS processors can be used with IBM MQ. They require you to setup an "JMSConnectionFactoryProvider" controller service to facilitate that IBM MQ connection. You will need to download the IBM MQ Client library on to the server where your NiFi is running.
Matt
Created 02-21-2017 03:58 PM
I had read the posts at https://community.hortonworks.com/questions/35871/consumejms-failed-to-load-the-websphere-mq-native.... and https://community.hortonworks.com/questions/35871/consumejms-failed-to-load-the-websphere-mq-native....
I followed the instructions to configure the onsumeJMS and PublishJMS processors, but I cannot get it working. I wonder it's the configuration issue on the IBM MQ. For example, 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?
Created 02-21-2017 04:27 PM
Andy
What happened with your previous post on the same subject? https://community.hortonworks.com/questions/84466/nifi-disabled-controller-services-and-consumejms-f...
Have you tried what I have suggested?
Thank you
Oleg
Created 02-21-2017 05:11 PM
@ozhurakousky Thanks a lot for taking time to help me. Yeah, I had tired your suggestion. and I just wrote a very detail message on what I did on the previous post.
Created 02-24-2017 10:32 PM
update: I finally figured out how to setup IBM MQ for Nifi
Here is my steps to setup IBM MQ for the Nifi connection
1) Create queue manager myMQManager using MQ Explorer
2) create Channel and queue using the following commands
runmqsc myMQManager
def chl(myMQChannel) chltype(svrconn) replace
def chl(myMQChannel) chltype(clntconn) conname('localhost(1420)') QMNAME('myMQManager') replace
def ql(myMQqueue)
2) Grant necessary authorization for a user using MQ Explorer
2.1 Queue Manager Authorities Setting
right click your queue manager-->Object Authorities-->Add Role Based Authorities -->give the user access permission
2.2 Queue Authorities Setting
right click your queue-->Object Authorities-->Manage Authority Records-->Specific Profiles--> your queue--> Accumulated authorities-->setup your user Access Permission for the queue
3) After the configuration and setup your Nifi ConsumeJMS processor, you should be able connect to IBM MQ