summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAsif Saif Uddin <auvipy@gmail.com>2021-11-18 17:57:54 +0600
committerAsif Saif Uddin <auvipy@gmail.com>2021-11-18 17:57:54 +0600
commit6ee1af5ca279c730aeeec5ac7934cdd0a07508c9 (patch)
tree26ea17011a30e847514c62be285d0a23eea7dd5e
parent8086a30d60372223812ab6853fcb784fdcb0e84d (diff)
downloadpy-amqp-6ee1af5ca279c730aeeec5ac7934cdd0a07508c9.tar.gz
added more experimental slots to classes
-rw-r--r--amqp/channel.py12
-rw-r--r--amqp/method_framing.py4
-rw-r--r--amqp/sasl.py17
-rw-r--r--amqp/transport.py4
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)