topic Re: Has anyone connected to RabbitMQ? in Workato Pros Discussion Board

Has anyone connected to RabbitMQ?

bboren — Fri, 03 May 2024 22:25:11 GMT

We have a customer looking to use Workato to connect to RAbbitMQ. Has anyone done that? Any pointers?

Thanks!

Re: Has anyone connected to RabbitMQ?

meghan-legaspi — Tue, 14 May 2024 18:26:57 GMT

Great question! Have you connected with your Workato rep to see what custom connection options you have? Looking forward to hearing more on this!

Thanks,
Meghan

Re: Has anyone connected to RabbitMQ?

mppowe — Tue, 21 May 2024 16:10:55 GMT

I haven't done it, but it might be worth looking at whether it's necessary or not. Your org may already be heavily invested in it, but if not another option could be leveraging Workato's own Pub/Sub capability. That way your recipes just tap into it without figuring out a connection elsewhere.

Re: Has anyone connected to RabbitMQ?

steven-marissen — Wed, 22 May 2024 14:18:17 GMT

In the case that Workato can't directly connect to RabbitMQ, there is also the option that for example Pika (a python rabbitMQ client library) can act like a consumer, process the messages, make API calls directly into Workato Pub/Sub using the platform API's. That way Pika acts like a 'dumb' forwarder with acknowledgement handling.

Re: Has anyone connected to RabbitMQ?

wspinrad — Wed, 13 Nov 2024 13:37:57 GMT

DId anyone get a definitive answer about connecting with RabbitMQ, I also have a customer in need,

Re: Has anyone connected to RabbitMQ?

timwolfe — Sun, 17 Nov 2024 03:28:26 GMT

[Using Workato SDK and RabbitMQ API Documentation as Ref]

You can use Python:

import requests
import pika
import json

# RabbitMQ connection settings
rabbitmq_host = 'your-rabbitmq-host'
queue_name = 'your-queue-name'

# Workato Webhook URL
workato_webhook_url = 'https://hooks.workato.com/webhooks/<your-webhook-id>'

# RabbitMQ connection
connection = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host))
channel = connection.channel()
channel.queue_declare(queue=queue_name)

# Message processing function
def callback(ch, method, properties, body):
message = json.loads(body)
# Send to Workato webhook
response = requests.post(workato_webhook_url, json=message)
print(f"Message sent to Workato: {response.status_code}")

channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)

print("Waiting for messages. To exit press CTRL+C")
channel.start_consuming()

---

This script:

1) Connects to RabbitMQ and listens to a queue.
2) Forwards any incoming messages to the Workato Webhook.

Re: Has anyone connected to RabbitMQ?

blakesha — Tue, 25 Feb 2025 03:42:48 GMT

There is the RabbitMQ Webhooks plugin, but it MAY be a bit outdated. (Never used it before, but worth investigating) - neuralegion/rabbitmq-webhooks - Docker Image | Docker Hub