-
Notifications
You must be signed in to change notification settings - Fork 4.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Added authentication support for AQMP broker url #8057
Changes from 7 commits
960338f
595d1e8
5774681
f149c37
41916be
f0babd8
f6151d7
896d682
1572fbd
5be0d9b
d40b11a
0551edd
171ce8d
e584ecd
0b63659
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -6,6 +6,7 @@ | |
from asyncio import AbstractEventLoop | ||
from collections import deque | ||
from typing import Deque, Dict, Optional, Text, Union, Any, List, Tuple | ||
from urllib.parse import urlparse | ||
|
||
import aio_pika | ||
|
||
|
@@ -168,7 +169,9 @@ async def _connect(self) -> aio_pika.RobustConnection: | |
# The `url` parameter will take precedence over parameters like `login` or | ||
# `password`. | ||
if self.host.startswith("amqp"): | ||
url = self.host | ||
|
||
host_ob = urlparse(self.host) | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. What does the name There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. @alwx There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Sounds better now, thanks! |
||
url = f"{host_ob.scheme}://{self.username}:{self.password}@{host_ob.netloc}:{self.port}" | ||
|
||
ssl_options = _create_rabbitmq_ssl_options(self.host) | ||
logger.info("Connecting to RabbitMQ ...") | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We don't usually change old changelog entries — the new one needs to be added instead. This guide contains the detailed information about the process: https://github.com/RasaHQ/rasa/blob/main/changelog/README.md
But to keep it short: could you please create a
8057.improvement.md
file inside achangelog
directory with all the information about what was done in this PR instead of modifyingCHANGELOG.mdx
?There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@alwx Sounds good!! removed change log entry and created new one as per your suggestion
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Awesome, thanks!