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 /tests | |
| 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 'tests')
| -rw-r--r-- | tests/unit/rpc/test_qpid.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/tests/unit/rpc/test_qpid.py b/tests/unit/rpc/test_qpid.py index b753c22..a7526c5 100644 --- a/tests/unit/rpc/test_qpid.py +++ b/tests/unit/rpc/test_qpid.py @@ -307,6 +307,7 @@ class RpcQpidTestCase(unittest.TestCase): self.mock_receiver) self.mock_receiver.fetch().AndReturn(qpid.messaging.Message( {"result": "foo", "failure": False, "ending": False})) + self.mock_session.acknowledge(mox.IgnoreArg()) if multi: self.mock_session.next_receiver(timeout=mox.IsA(int)).AndReturn( self.mock_receiver) @@ -314,16 +315,19 @@ class RpcQpidTestCase(unittest.TestCase): qpid.messaging.Message( {"result": "bar", "failure": False, "ending": False})) + self.mock_session.acknowledge(mox.IgnoreArg()) self.mock_session.next_receiver(timeout=mox.IsA(int)).AndReturn( self.mock_receiver) self.mock_receiver.fetch().AndReturn( qpid.messaging.Message( {"result": "baz", "failure": False, "ending": False})) + self.mock_session.acknowledge(mox.IgnoreArg()) self.mock_session.next_receiver(timeout=mox.IsA(int)).AndReturn( self.mock_receiver) self.mock_receiver.fetch().AndReturn(qpid.messaging.Message( {"failure": False, "ending": True})) + self.mock_session.acknowledge(mox.IgnoreArg()) self.mock_session.close() self.mock_connection.session().AndReturn(self.mock_session) |