Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[pyamqp] require amqp 0.9.3

This commit is contained in:
Ask Solem 2012-08-29 16:01:33 +01:00
parent 198c4ce1d7
commit 1b07173f56
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kombu/transport/pyamqp.py
View File

@ -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):