From 4b41cb0992413c07849779c763d31abb0883987b Mon Sep 17 00:00:00 2001
From: Ask Solem <ask@celeryproject.org>
Date: Mon, 26 Oct 2015 19:39:55 -0700
Subject: [PATCH] Adds Connection.supports_exchange_type(type)

---
 kombu/connection.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/kombu/connection.py b/kombu/connection.py
index 8b721edc..f051dc8c 100644
--- a/kombu/connection.py
+++ b/kombu/connection.py
@@ -700,6 +700,9 @@ class Connection(object):
         self._debug('connection established: %r', self)
         return conn
 
+    def supports_exchange_type(self, exchange_type):
+        return exchange_type in self.transport.implements.exchange_type
+
     def __repr__(self):
         """``x.__repr__() <==> repr(x)``"""
         return '<Connection: {0} at {1:#x}>'.format(self.as_uri(), id(self))