[NATS] How to connect to Synadia Cloud?

[ericsouza]

Hey 👋🏻

I'm trying to use Synadia Cloud (a NATS as a service solution) with faststream but I'm not able to connect to synadia.

faststream app example:

import logging
from faststream import FastStream
from faststream.nats import NatsBroker

async def error_cb(e):
    logging.error("error: ", e)

broker = NatsBroker("tls://connect.ngs.global", user_credentials="path/to/my/credentials.creds", error_cb=error_cb, timeout=30)

app = FastStream(broker)


@broker.subscriber("test")
async def base_handler(body):
    print(body)

The logged error is a Timeout. I don't think is a timeout to connect because the raw nats version connects in less than a second

raw nats-py example:

from nats import NATS
import asyncio

nc = NATS()

async def error_cb(e):
    print("Error:", e)

async def main():
    await nc.connect("tls://connect.ngs.global", user_credentials="path/to/my/credentials.creds", error_cb=error_cb)
    print("Is connected: ", nc.is_connected)
    await nc.close()

asyncio.run(main())

[ericsouza]

Oh man 🤦🏻

It was just the missing port. We must add 4222 to the tls host:

broker = NatsBroker("tls://connect.ngs.global:4222", user_credentials="path/to/my/credentials.creds", error_cb=error_cb, timeout=5)