diff options
Diffstat (limited to 'kombu/transport/sqlalchemy/__init__.py')
| -rw-r--r-- | kombu/transport/sqlalchemy/__init__.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/sqlalchemy/__init__.py b/kombu/transport/sqlalchemy/__init__.py index fe469fae..da34b8f6 100644 --- a/kombu/transport/sqlalchemy/__init__.py +++ b/kombu/transport/sqlalchemy/__init__.py @@ -99,7 +99,7 @@ class Channel(virtual.Channel): self.session.execute('BEGIN IMMEDIATE TRANSACTION') try: msg = self.session.query(self.message_cls) \ - .with_lockmode('update') \ + .with_for_update() \ .filter(self.message_cls.queue_id == obj.id) \ .filter(self.message_cls.visible != False) \ .order_by(self.message_cls.sent_at) \ |