File tree Expand file tree Collapse file tree 5 files changed +10
-8
lines changed
rabbitmq_amqp_python_client Expand file tree Collapse file tree 5 files changed +10
-8
lines changed Original file line number Diff line number Diff line change 77 BindingSpecification ,
88 Connection ,
99 Disposition ,
10+ Environment ,
1011 Event ,
1112 ExchangeSpecification ,
1213 Message ,
1314 QuorumQueueSpecification ,
14- Environment ,
1515)
1616
1717MESSAGES_TO_PUBLISH = 100
Original file line number Diff line number Diff line change 44 AddressHelper ,
55 AMQPMessagingHandler ,
66 Connection ,
7+ Environment ,
78 Event ,
89 Message ,
910 OffsetSpecification ,
1011 StreamOptions ,
1112 StreamSpecification ,
12- Environment ,
1313)
1414
1515MESSAGES_TO_PUBLISH = 100
Original file line number Diff line number Diff line change 1212 Connection ,
1313 ConnectionClosed ,
1414 Consumer ,
15+ Environment ,
1516 Event ,
1617 ExchangeSpecification ,
1718 Management ,
1819 Message ,
1920 Publisher ,
2021 QuorumQueueSpecification ,
21- Environment ,
2222)
2323
2424environment = Environment ()
25+
26+
2527# here we keep track of the objects we need to reconnect
2628@dataclass
2729class ConnectionConfiguration :
Original file line number Diff line number Diff line change 77 BindingSpecification ,
88 ClientCert ,
99 Connection ,
10+ Environment ,
1011 Event ,
1112 ExchangeSpecification ,
1213 Message ,
1314 QuorumQueueSpecification ,
1415 SslConfigurationContext ,
15- Environment ,
1616)
1717
1818messages_to_publish = 100
Original file line number Diff line number Diff line change @@ -16,15 +16,15 @@ def __init__(self): # type: ignore
1616 def connection (
1717 self ,
1818 # single-node mode
19- url : Optional [str ] = None ,
19+ uri : Optional [str ] = None ,
2020 # multi-node mode
21- urls : Optional [list [str ]] = None ,
21+ uris : Optional [list [str ]] = None ,
2222 ssl_context : Optional [SslConfigurationContext ] = None ,
2323 on_disconnection_handler : Optional [CB ] = None , # type: ignore
2424 ) -> Connection :
2525 connection = Connection (
26- url = url ,
27- urls = urls ,
26+ uri = uri ,
27+ uris = uris ,
2828 ssl_context = ssl_context ,
2929 on_disconnection_handler = on_disconnection_handler ,
3030 )
You can’t perform that action at this time.
0 commit comments