From 1b07173f5613fa82cb5f016b87a9c18021297d63 Mon Sep 17 00:00:00 2001
From: Ask Solem <ask@celeryproject.org>
Date: Wed, 29 Aug 2012 16:01:33 +0100
Subject: [PATCH] [pyamqp] require amqp 0.9.3

---
 kombu/transport/pyamqp.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py
index 2ad938c7..aff61703 100644
--- a/kombu/transport/pyamqp.py
+++ b/kombu/transport/pyamqp.py
@@ -12,13 +12,16 @@ from __future__ import absolute_import
 
 import amqp
 
-from kombu.exceptions import StdChannelError
+from kombu.exceptions import StdChannelError, VersionMismatch
 from kombu.utils.amq_manager import get_manager
 
 from . import base
 
 DEFAULT_PORT = 5672
 
+if amqp.VERSION < (0, 9, 3):
+    raise VersionMismatch('Please install amqp version 0.9.3 or higher.')
+
 
 class Message(base.Message):