File tree Expand file tree Collapse file tree 1 file changed +1
-5
lines changed
rabbitmq_amqp_python_client Expand file tree Collapse file tree 1 file changed +1
-5
lines changed Original file line number Diff line number Diff line change 5
5
from .qpid .proton ._message import Message
6
6
from .qpid .proton .utils import (
7
7
BlockingConnection ,
8
- BlockingReceiver ,
9
8
BlockingSender ,
10
9
)
11
10
15
14
class Publisher :
16
15
def __init__ (self , conn : BlockingConnection , addr : str ):
17
16
self ._sender : Optional [BlockingSender ] = None
18
- self ._receiver : Optional [BlockingReceiver ] = None
19
17
self ._conn = conn
20
18
self ._addr = addr
21
19
self ._open ()
@@ -30,11 +28,9 @@ def publish(self, message: Message) -> None:
30
28
self ._sender .send (message )
31
29
32
30
def close (self ) -> None :
33
- logger .debug ("Closing Sender and Receiver " )
31
+ logger .debug ("Closing Sender" )
34
32
if self ._sender is not None :
35
33
self ._sender .close ()
36
- if self ._receiver is not None :
37
- self ._receiver .close ()
38
34
39
35
def _create_sender (self , addr : str ) -> BlockingSender :
40
36
return self ._conn .create_sender (addr , options = SenderOption (addr ))
You can’t perform that action at this time.
0 commit comments