diff options
author | Asif Saif Uddin <auvipy@gmail.com> | 2021-11-18 17:57:54 +0600 |
---|---|---|
committer | Asif Saif Uddin <auvipy@gmail.com> | 2021-11-18 17:57:54 +0600 |
commit | 6ee1af5ca279c730aeeec5ac7934cdd0a07508c9 (patch) | |
tree | 26ea17011a30e847514c62be285d0a23eea7dd5e | |
parent | 8086a30d60372223812ab6853fcb784fdcb0e84d (diff) | |
download | py-amqp-6ee1af5ca279c730aeeec5ac7934cdd0a07508c9.tar.gz |
added more experimental slots to classes
-rw-r--r-- | amqp/channel.py | 12 | ||||
-rw-r--r-- | amqp/method_framing.py | 4 | ||||
-rw-r--r-- | amqp/sasl.py | 17 | ||||
-rw-r--r-- | amqp/transport.py | 4 |
4 files changed, 37 insertions, 0 deletions
diff --git a/amqp/channel.py b/amqp/channel.py index b271820..281fc46 100644 --- a/amqp/channel.py +++ b/amqp/channel.py @@ -122,6 +122,18 @@ class Channel(AbstractChannel): if self.connection.confirm_publish: self.basic_publish = self.basic_publish_confirm + __slots__ = ( + "is_open", + "active", + "returned_messages", + "callbacks", + "cancel_callbacks", + "events", + "no_ack_consumers", + "on_open", + "_confirm_selected", + ) + def then(self, on_success, on_error=None): return self.on_open.then(on_success, on_error) diff --git a/amqp/method_framing.py b/amqp/method_framing.py index 5fe0505..658061e 100644 --- a/amqp/method_framing.py +++ b/amqp/method_framing.py @@ -87,6 +87,10 @@ class Buffer: def __init__(self, buf): self.buf = buf + __slots__ = ( + "buf", + ) + @property def buf(self): return self._buf diff --git a/amqp/sasl.py b/amqp/sasl.py index 9a98a7a..407ccb8 100644 --- a/amqp/sasl.py +++ b/amqp/sasl.py @@ -34,6 +34,11 @@ class PLAIN(SASL): def __init__(self, username, password): self.username, self.password = username, password + __slots__ = ( + "username", + "password", + ) + def start(self, connection): if self.username is None or self.password is None: return NotImplemented @@ -56,6 +61,11 @@ class AMQPLAIN(SASL): def __init__(self, username, password): self.username, self.password = username, password + __slots__ = ( + "username", + "password", + ) + def start(self, connection): if self.username is None or self.password is None: return NotImplemented @@ -104,6 +114,13 @@ def _get_gssapi_mechanism(): self.service = service self.rdns = rdns + __slots__ = ( + "client_name", + "fail_soft", + "service", + "rdns" + ) + def get_hostname(self, connection): sock = connection.transport.sock if self.rdns and sock.family in (socket.AF_INET, diff --git a/amqp/transport.py b/amqp/transport.py index 8a355d7..cebd3b6 100644 --- a/amqp/transport.py +++ b/amqp/transport.py @@ -415,6 +415,10 @@ class SSLTransport(_AbstractTransport): super().__init__( host, connect_timeout=connect_timeout, **kwargs) + __slots__ = ( + "sslopts", + ) + def _setup_transport(self): """Wrap the socket in an SSL object.""" self.sock = self._wrap_socket(self.sock, **self.sslopts) |