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

amqplib's handshake mistakenly identifies as protocol version 1191, 

this breaks in RabbitMQ tip, which no longer falls back to
0-8 for unknown ids.
This commit is contained in:
Ask Solem 2010-08-02 12:39:09 +02:00
parent a3f67ffce8
commit 1492b7c689
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kombu/backends/pyamqplib.py
View File

@ -1,6 +1,7 @@
import socket
from amqplib import client_0_8 as amqp
frmo amqplib.client_0_8 import transport
from amqplib.client_0_8.channel import Channel
from amqplib.client_0_8.exceptions import AMQPConnectionException
from amqplib.client_0_8.exceptions import AMQPChannelException
@ -9,6 +10,11 @@ from kombu.backends.base import BaseMessage, BaseBackend
DEFAULT_PORT = 5672
# amqplib's handshake mistakenly identifies as protocol version 1191,
# this breaks in RabbitMQ tip, which no longer falls back to
# 0-8 for unknown ids.
transport.AMQP_PROTOCOL_HEADER = "AMQP\x01\x01\x08\x00"
class Connection(amqp.Connection):
def _dispatch_basic_return(self, channel, args, msg):