diff options
Diffstat (limited to 'qpid/cpp/src/tests/queue_flow_limit_tests.py')
| -rw-r--r-- | qpid/cpp/src/tests/queue_flow_limit_tests.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/qpid/cpp/src/tests/queue_flow_limit_tests.py b/qpid/cpp/src/tests/queue_flow_limit_tests.py index 9bfba28e15..27fbe2afcc 100644 --- a/qpid/cpp/src/tests/queue_flow_limit_tests.py +++ b/qpid/cpp/src/tests/queue_flow_limit_tests.py @@ -53,13 +53,13 @@ class QueueFlowLimitTests(TestBase010): if i.name == name: # verify flow settings if (stop_count is not None): - self.assertEqual(i.flowStopCount, stop_count) + self.assertEqual(i.arguments.get("qpid.flow_stop_count"), stop_count) if (resume_count is not None): - self.assertEqual(i.flowResumeCount, resume_count) + self.assertEqual(i.arguments.get("qpid.flow_resume_count"), resume_count) if (stop_size is not None): - self.assertEqual(i.flowStopSize, stop_size) + self.assertEqual(i.arguments.get("qpid.flow_stop_size"), stop_size) if (resume_size is not None): - self.assertEqual(i.flowResumeSize, resume_size) + self.assertEqual(i.arguments.get("qpid.flow_resume_size"), resume_size) self.assertFalse(i.flowStopped) return i.getObjectId() self.fail("Unable to create queue '%s'" % name) @@ -123,10 +123,10 @@ class QueueFlowLimitTests(TestBase010): qs = self.qmf.getObjects(_class="queue") for i in qs: if i.name == "test01": - self.assertEqual(i.flowStopCount, 999) - self.assertEqual(i.flowResumeCount, 55) - self.assertEqual(i.flowStopSize, 5000000) - self.assertEqual(i.flowResumeSize, 100000) + self.assertEqual(i.arguments.get("qpid.flow_stop_count"), 999) + self.assertEqual(i.arguments.get("qpid.flow_resume_count"), 55) + self.assertEqual(i.arguments.get("qpid.flow_stop_size"), 5000000) + self.assertEqual(i.arguments.get("qpid.flow_resume_size"), 100000) self.assertFalse(i.flowStopped) break; self.assertEqual(i.name, "test01") |