Integration with RabbitMQ
One of the requirements in my project is to connect to RabbitMQ for sending and receiving messages. As I understand there is no native support from Pega to integrate with RabbitMQ but JMS or Java client libraries that RMQ provides could to be used to integrate.
Since there are certain known limitations to use JMS with RMQ, we are planning on using Java client.
we need a program to keep pooling messages from the queue.
I need help/guidelines on how to set this up and running,
Pegasystems Inc.
IN
Hi,
Configuration Steps:
Hi,
Configuration Steps:
- Install RabbitMQ
- Install RabbitMQ JMS Client: You might need to do the "Enabling the Topic Selector Plug-in"
- copy client jars to your application server lib directory
- Start RabbitMQ server: I used the "rabbitmq-server" command to start it on my Mac
- Prepare your application server:
- This step depends on your application server, I used Tomcat and included the required JNDI resources below.
- make sure the rap contains:
- All required JARS
- Sample JMS listener "RabbitMQ"
- Sample JNDI Server "Localhost_1"
- Sample Service Package "RabbitMQ"
- Sample JMS Service "RabbitMQTest"
- Sample activity to process message "ProcessRabbitMqMsg"
- Sample activity to create a RabbitMQ queue, destination and send messages for testing "SendRabbitMQMsg"
- Restart your application server
- Create JMS Service, Listener, etc.
- Start the JMS listener
- Run the SendRabbitMQMsg activity to test
Required Tomcat JNDI resources:
<Resource name="jms/ConnectionFactory"
type="javax.jms.ConnectionFactory"
factory="com.rabbitmq.jms.admin.RMQObjectFactory"
username="guest"
password="guest"
virtualHost="/"
host="localhost"/>
<Resource name="jms/PegaQueue"
type="javax.jms.Queue"
factory="com.rabbitmq.jms.admin.RMQObjectFactory"
destinationName=""
amqpExchangeName="pegasystems"
amqpRoutingKey="pega.app.*"
amqp="true"
amqpQueueName="pega" />
Hope this will help you.
Genentech Inc
US
Hi Narasimha,
Thanks for your response. I am working on getting the JMS setup but since RMQ has certain limitations with JMS, I need a way to set up the integration with the java client for RMQ. Please let me know if you had experience setting the connection using a Java client. Thanks.
-Giri
Genentech Inc
US
Hi Sudhakar,
Thanks for your response! I have used JMS to integrate and it works but I want to get it working using the Java client since it has full support for amqp integration to RabbitMQ. Any inputs on it would be really useful.
Thanks!
Pegasystems Inc.
Hi Narasimha522,
We are also trying to do the same. I have setup the JNDI server and its connecting fine. However when we are trying to connect to the queue from JMS Listener, its timing out with socket closed exception. Could you help with the possible reason. And also could you tell me whats the difference between destinationName and AMPQQueue name. It would be very helpful if you could share your rabbit MQ configs too. So that I can map it to the attributes in <Resource name="jms/PegaQueue"> .
-Thanks
Anupam
Pegasystems Inc.
IN
Hi,
Thank you for posting your query in the PSC. This looks like an inactive post and hence, we suggest you create a new post for your query. Click on the Write Post button here. Once created, please reply back here with the URL of the new post.
You may also refer this discussion link as a reference in the new thread.