diff options
Diffstat (limited to 'kombu/transport/beanstalk.py')
| -rw-r--r-- | kombu/transport/beanstalk.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/beanstalk.py b/kombu/transport/beanstalk.py index 9dff8b49..544fd438 100644 --- a/kombu/transport/beanstalk.py +++ b/kombu/transport/beanstalk.py @@ -44,7 +44,7 @@ class Channel(virtual.Channel): def _put(self, queue, message, **kwargs): extra = {} - priority = message['properties']['delivery_info']['priority'] + priority = self._get_message_priority(message) ttr = message['properties'].get('ttr') if ttr is not None: extra['ttr'] = ttr |