Send message_id as property

message_id field should be sent as message property, not as
field in message headers

Change-Id: Ibe0fc32136c719e62eb2ce8557f3063c8aa387fd
Closes-Bug: #1322078
This commit is contained in:
Serg Melikyan 2014-05-23 14:49:23 +04:00
parent a9bf465455
commit a15e43c80d
2 changed files with 2 additions and 4 deletions

View File

@ -25,7 +25,7 @@ class Message(object):
self._connection = connection
self._message_handle = message_handle
if message_handle:
self.id = message_handle.headers.get('message_id')
self.id = message_handle.properties.get('message_id')
else:
self.id = None

View File

@ -91,14 +91,12 @@ class MqClient(object):
if not self._connected:
raise RuntimeError('Not connected to RabbitMQ')
headers = {'message_id': str(message.id)}
producer = kombu.Producer(self._connection)
producer.publish(
exchange=str(exchange),
routing_key=str(key),
body=anyjson.dumps(message.body),
headers=headers
message_id=str(message.id)
)
def open(self, queue, prefetch_count=1):