Merge pull request #1210 from keith-bennett-gbg/keithb/blocking-chann…

…el-consumer-tags

add consumer_tags property to BlockingChannel

pika/adapters/blocking_connection.py

@@ -1303,6 +1303,16 @@ def is_open(self):
         """
         return self._impl.is_open
 
+    @property
+    def consumer_tags(self):
+        """Property method that returns a list of consumer tags for active
+        consumers
+
+        :rtype: list
+
+        """
+        return compat.dictkeys(self._consumer_infos)
+
     _ALWAYS_READY_WAITERS = ((lambda: True),)
 
     def _flush_output(self, *waiters):

tests/unit/blocking_channel_tests.py

@@ -113,3 +113,12 @@ def test_context_manager_exit_with_closed_channel(self):
             chan.close()
         chan._impl.close.assert_called_with(
             reply_code=0, reply_text='Normal shutdown')
+
+    def test_consumer_tags_property(self):
+        with mock.patch.object(self.obj._impl, '_generate_consumer_tag'):
+            self.assertEqual(0, len(self.obj.consumer_tags))
+            self.obj._impl._generate_consumer_tag.return_value = 'ctag0'
+            self.obj._impl.basic_consume.return_value = 'ctag0'
+            self.obj.basic_consume('queue', mock.Mock())
+            self.assertEqual(1, len(self.obj.consumer_tags))
+            self.assertIn('ctag0', self.obj.consumer_tags)