From bb0bb5298b5e2c3ea75587646b173c6ac4fbd3a2 Mon Sep 17 00:00:00 2001
From: Josh Morrow <josh@jcmorrow.com>
Date: Tue, 5 Feb 2019 02:32:53 -0500
Subject: Allow mutex to be noop for eventlet (#916)

---
 kombu/resource.py | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/kombu/resource.py b/kombu/resource.py
index 1d13edcb..b9715d4a 100644
--- a/kombu/resource.py
+++ b/kombu/resource.py
@@ -188,9 +188,16 @@ class Resource(object):
             self._shrink_down(collect=limit > 0)
 
     def _shrink_down(self, collect=True):
+        class Noop:
+            def __enter__(self):
+                pass
+
+            def __exit__(self, type, value, traceback):
+                pass
+
         resource = self._resource
         # Items to the left are last recently used, so we remove those first.
-        with resource.mutex:
+        with getattr(resource, 'mutex', Noop()):
             while len(resource.queue) > self.limit:
                 R = resource.queue.popleft()
                 if collect:
-- 
cgit v1.2.1