diff options
author | Stephen D. Huston <shuston@apache.org> | 2013-06-06 17:22:33 +0000 |
---|---|---|
committer | Stephen D. Huston <shuston@apache.org> | 2013-06-06 17:22:33 +0000 |
commit | 21595f68ca9cf31e2c03ef638873ebffa0f526ef (patch) | |
tree | 764459b427b144a7a2a4491427b024c84e4d01b7 | |
parent | 8970e91dec9823012315ad07030d9bedecbeaad1 (diff) | |
download | qpid-python-21595f68ca9cf31e2c03ef638873ebffa0f526ef.tar.gz |
Add a test for recovering a message with 0-length body. NO-JIRA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1490365 13f79535-47bb-0310-9956-ffa450edef68
-rwxr-xr-x | cpp/src/tests/store.py | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/cpp/src/tests/store.py b/cpp/src/tests/store.py index 77e8a78e5d..5c1934dded 100755 --- a/cpp/src/tests/store.py +++ b/cpp/src/tests/store.py @@ -127,6 +127,12 @@ class StoreTests(BrokerTest): self.ssn.exchange_declare(exchange="DB_E1", type="direct", durable=True) self.ssn.exchange_bind(exchange="DB_E1", queue="DB_Q1", binding_key="K1") + # Queue up 2 messages, one with non-zero body, one with zero-length. + # 2 = delivery_mode.persistent + dp = self.ssn.delivery_properties(routing_key="DB_Q1", delivery_mode=2) + self.ssn.message_transfer(message=Message(dp, "normal message")) + self.ssn.message_transfer(message=Message(dp, "")) + # Cycle the broker and make sure the binding recovers self.cycle_broker() response = self.ssn.exchange_bound(exchange="DB_E1", queue="DB_Q1", binding_key="K1") @@ -135,6 +141,17 @@ class StoreTests(BrokerTest): self.assert_(not response.queue_not_matched) self.assert_(not response.key_not_matched) + # Are the messages still there? + self.ssn.message_subscribe(destination="msgs", queue="DB_Q1", accept_mode=1, acquire_mode=0) + self.ssn.message_flow(unit = 1, value = 0xFFFFFFFFL, destination = "msgs") + self.ssn.message_flow(unit = 0, value = 10, destination = "msgs") + message_arrivals = self.ssn.incoming("msgs") + try: + message_arrivals.get(timeout=1) + message_arrivals.get(timeout=1) + except Empty: + assert False, 'Durable message(s) not recovered' + self.ssn.exchange_unbind(queue="DB_Q1", exchange="DB_E1", binding_key="K1") self.ssn.exchange_delete(exchange="DB_E1") self.ssn.queue_delete(queue="DB_Q1") |