Merge pull request #1111 from abompard/twisted-channel-fix

Twisted channel: relay the consumer_tags property
pika · Aug 24, 2018 · 706ac7e · 706ac7e
2 parents b74870b + edbdeb9
commit 706ac7e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pika/adapters/twisted_connection.py b/pika/adapters/twisted_connection.py
@@ -274,6 +274,10 @@ def is_open(self):
     def flow_active(self):
         return self._channel.flow_active
 
+    @property
+    def consumer_tags(self):
+        return self._channel.consumer_tags
+
     # Deferred-equivalents of public Channel methods
 
     def callback_deferred(self, deferred, replies):

diff --git a/tests/acceptance/twisted_adapter_tests.py b/tests/acceptance/twisted_adapter_tests.py
@@ -271,7 +271,7 @@ def test_passthrough(self):
         # Check the simple attribute passthroughs
         attributes = (
             "channel_number", "connection", "is_closed", "is_closing",
-            "is_open", "flow_active",
+            "is_open", "flow_active", "consumer_tags",
         )
         for name in attributes:
             value = "testvalue-{}".format(name)