We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b2b601 commit 40790bcCopy full SHA for 40790bc
tests/test_address_helper.py
@@ -0,0 +1,16 @@
1
+from rabbitmq_amqp_python_client import queue_address
2
+
3
+def test_encoding_simple() -> None:
4
+ queue = "my_queue"
5
6
+ address = queue_address(queue)
7
8
+ assert address == "/queues/my_queue"
9
10
+def test_encoding_hex() -> None:
11
+ queue = "my_queue>"
12
13
14
15
+ assert address == "/queues/my_queue%3E"
16
tests/test_management.py
@@ -30,7 +30,7 @@ def test_declare_delete_queue() -> None:
30
connection = Connection("amqp://guest:guest@localhost:5672/")
31
connection.dial()
32
33
- queue_name = "test-queue"
+ queue_name = "my_queue>"
34
management = connection.management()
35
36
queue_info = management.declare_queue(
0 commit comments