diff options
| author | Jenkins <jenkins@review.openstack.org> | 2012-06-15 13:13:36 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2012-06-15 13:13:36 +0000 |
| commit | 925edb3ee8bbd97afaa43b2888ab45d2bca50faf (patch) | |
| tree | 262f3809e2222e321816182066d1b96a7b4a6f96 /openstack/common/rpc/impl_qpid.py | |
| parent | c092bd596287a2a66938d01152ea8dbade1926b6 (diff) | |
| parent | 341ae3b475f9aab85c9202995529b1d041a71b2b (diff) | |
| download | oslo-925edb3ee8bbd97afaa43b2888ab45d2bca50faf.tar.gz oslo-925edb3ee8bbd97afaa43b2888ab45d2bca50faf.tar.xz oslo-925edb3ee8bbd97afaa43b2888ab45d2bca50faf.zip | |
Merge "Add missing ack to impl_qpid."
Diffstat (limited to 'openstack/common/rpc/impl_qpid.py')
| -rw-r--r-- | openstack/common/rpc/impl_qpid.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_qpid.py b/openstack/common/rpc/impl_qpid.py index 3c46309..78236f2 100644 --- a/openstack/common/rpc/impl_qpid.py +++ b/openstack/common/rpc/impl_qpid.py @@ -138,7 +138,12 @@ class ConsumerBase(object): def consume(self): """Fetch the message and pass it to the callback object""" message = self.receiver.fetch() - self.callback(message.content) + try: + self.callback(message.content) + except Exception: + logging.exception(_("Failed to process message... skipping it.")) + finally: + self.session.acknowledge(message) def get_receiver(self): return self.receiver |