diff options
| author | Ask Solem <ask@celeryproject.org> | 2015-10-20 13:55:35 -0700 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2015-10-20 13:55:35 -0700 |
| commit | f47d99faf397fb8ab282513a2081a59b96feb75f (patch) | |
| tree | b7afce85dbbd8d537f423fa1d9ccb42f16c8d26d | |
| parent | 73a3dfb4f1fcc4a82bbbfa5ded0020668ce1f725 (diff) | |
| download | kombu-f47d99faf397fb8ab282513a2081a59b96feb75f.tar.gz | |
Message: priority is a property, not delivery_info (Issue celery/celery#2868) Backward incompatible
| -rw-r--r-- | kombu/transport/virtual/__init__.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/virtual/__init__.py b/kombu/transport/virtual/__init__.py index 1b0dd471..3ef13e41 100644 --- a/kombu/transport/virtual/__init__.py +++ b/kombu/transport/virtual/__init__.py @@ -661,8 +661,8 @@ class Channel(AbstractChannel, base.StdChannel): content_encoding=None, headers=None, properties=None): """Prepare message data.""" properties = properties or {} - info = properties.setdefault('delivery_info', {}) - info['priority'] = priority or self.default_priority + properties.setdefault('delivery_info', {}) + properties.setdefault('priority', priority or self.default_priority) return {'body': body, 'content-encoding': content_encoding, |