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 55from .qpid .proton ._message import Message
66from .qpid .proton .utils import (
77 BlockingConnection ,
8- BlockingReceiver ,
98 BlockingSender ,
109)
1110
1514class Publisher :
1615 def __init__ (self , conn : BlockingConnection , addr : str ):
1716 self ._sender : Optional [BlockingSender ] = None
18- self ._receiver : Optional [BlockingReceiver ] = None
1917 self ._conn = conn
2018 self ._addr = addr
2119 self ._open ()
@@ -30,11 +28,9 @@ def publish(self, message: Message) -> None:
3028 self ._sender .send (message )
3129
3230 def close (self ) -> None :
33- logger .debug ("Closing Sender and Receiver " )
31+ logger .debug ("Closing Sender" )
3432 if self ._sender is not None :
3533 self ._sender .close ()
36- if self ._receiver is not None :
37- self ._receiver .close ()
3834
3935 def _create_sender (self , addr : str ) -> BlockingSender :
4036 return self ._conn .create_sender (addr , options = SenderOption (addr ))
You can’t perform that action at this time.
0 commit comments