1
+ import logging
1
2
import uuid
2
3
from typing import Any , Optional
3
4
24
25
from .exceptions import ValidationCodeException
25
26
from .options import ReceiverOption , SenderOption
26
27
28
+ logger = logging .getLogger (__name__ )
29
+
27
30
28
31
class Management :
29
32
def __init__ (self , conn : BlockingConnection ):
@@ -33,10 +36,12 @@ def __init__(self, conn: BlockingConnection):
33
36
34
37
def open (self ) -> None :
35
38
if self ._sender is None :
39
+ logger .debug ("Creating Sender" )
36
40
self ._sender = self ._create_sender (
37
41
CommonValues .management_node_address .value
38
42
)
39
43
if self ._receiver is None :
44
+ logger .debug ("Creating Receiver" )
40
45
self ._receiver = self ._create_receiver (
41
46
CommonValues .management_node_address .value ,
42
47
)
@@ -49,6 +54,7 @@ def _create_receiver(self, addr: str) -> BlockingReceiver:
49
54
50
55
# closes the connection to the AMQP 1.0 server.
51
56
def close (self ) -> None :
57
+ logger .debug ("Closing Sender and Receiver" )
52
58
if self ._sender is not None :
53
59
self ._sender .close ()
54
60
if self ._receiver is not None :
@@ -80,16 +86,19 @@ def _request(
80
86
)
81
87
82
88
if self ._sender is not None :
89
+ logger .debug ("Sending message: " + str (amq_message ))
83
90
self ._sender .send (amq_message )
84
91
85
92
if self ._receiver is not None :
86
93
msg = self ._receiver .receive ()
94
+ logger .debug ("Received message: " + str (msg ))
87
95
88
96
self ._validate_reponse_code (int (msg .subject ), expected_response_codes )
89
97
90
98
def declare_exchange (
91
99
self , exchange_specification : ExchangeSpecification
92
100
) -> ExchangeSpecification :
101
+ logger .debug ("delete_exchange operation called" )
93
102
body = {}
94
103
body ["auto_delete" ] = exchange_specification .is_auto_delete
95
104
body ["durable" ] = exchange_specification .is_durable
@@ -115,6 +124,7 @@ def declare_exchange(
115
124
def declare_queue (
116
125
self , queue_specification : QueueSpecification
117
126
) -> QueueSpecification :
127
+ logger .debug ("declare_queue operation called" )
118
128
body = {}
119
129
body ["auto_delete" ] = queue_specification .is_auto_delete
120
130
body ["durable" ] = queue_specification .is_durable
@@ -141,6 +151,7 @@ def declare_queue(
141
151
return queue_specification
142
152
143
153
def delete_exchange (self , exchange_name : str ) -> None :
154
+ logger .debug ("delete_exchange operation called" )
144
155
path = exchange_address (exchange_name )
145
156
146
157
print (path )
@@ -155,6 +166,7 @@ def delete_exchange(self, exchange_name: str) -> None:
155
166
)
156
167
157
168
def delete_queue (self , queue_name : str ) -> None :
169
+ logger .debug ("delete_queue operation called" )
158
170
path = queue_address (queue_name )
159
171
160
172
self .request (
@@ -169,7 +181,7 @@ def delete_queue(self, queue_name: str) -> None:
169
181
def _validate_reponse_code (
170
182
self , response_code : int , expected_response_codes : list [int ]
171
183
) -> None :
172
- print ("response_code received: " + str (response_code ))
184
+ logger . debug ("response_code received: " + str (response_code ))
173
185
if response_code == CommonValues .response_code_409 .value :
174
186
# TODO replace with a new defined Exception
175
187
raise ValidationCodeException ("ErrPreconditionFailed" )
@@ -184,6 +196,7 @@ def _validate_reponse_code(
184
196
185
197
# TODO
186
198
def bind (self , bind_specification : BindingSpecification ) -> str :
199
+ logger .debug ("Bind Operation called" )
187
200
body = {}
188
201
body ["binding_key" ] = bind_specification .binding_key
189
202
body ["source" ] = bind_specification .source_exchange
@@ -206,6 +219,7 @@ def bind(self, bind_specification: BindingSpecification) -> str:
206
219
207
220
# TODO
208
221
def unbind (self , binding_exchange_queue_path : str ) -> None :
222
+ logger .debug ("UnBind Operation called" )
209
223
self .request (
210
224
None ,
211
225
binding_exchange_queue_path ,
0 commit comments