Skip to content

Commit

Permalink
idk
Browse files Browse the repository at this point in the history
  • Loading branch information
FelixTJDietrich committed Aug 17, 2024
1 parent d82fd48 commit b67f922
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions server/webhook-ingest/app/nats_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,10 +10,10 @@ def __init__(self, nats_url: str, nats_auth_token: str):
self.nats_auth_token = nats_auth_token

async def connect(self):
protocol, host = self.nats_url.split("://")
server_url = f"{protocol}://{self.nats_auth_token}@{host}"
logger.info(f"Connecting to NATS at {server_url}")
await self.nc.connect(server_url)
# protocol, host = self.nats_url.split("://")
# server_url = f"{protocol}://{self.nats_auth_token}@{host}"
# logger.info(f"Connecting to NATS at {server_url}")
await self.nc.connect(servers=self.nats_url, user=self.nats_auth_token)
self.js = self.nc.jetstream()
logger.info(f"Connected to NATS at {self.nats_url}")

Expand Down

0 comments on commit b67f922

Please sign in to comment.