mirror of https://github.com/celery/kombu.git
[issue #149] transport/librabbitmq: KeyError prevents further handling
Kombu ordinarily sets the `content_type` and `content_encoding` standard AMQP properties; in the event a message enters circulation *without* these headers, Kombu triggers a KeyError, and enters an unrecoverable loop precluding user handlers from ever reviewing, or even *recieving* the message.
This commit is contained in:
parent
5456a6bbeb
commit
6cf7857250
|
@ -39,9 +39,9 @@ class Message(base.Message):
|
|||
body=body,
|
||||
delivery_info=info,
|
||||
properties=props,
|
||||
delivery_tag=info['delivery_tag'],
|
||||
content_type=props['content_type'],
|
||||
content_encoding=props['content_encoding'],
|
||||
delivery_tag=info.get('delivery_tag'),
|
||||
content_type=props.get('content_type'),
|
||||
content_encoding=props.get('content_encoding'),
|
||||
headers=props.get('headers'))
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue