openstack/zaqar
Code Issues Proposed changes

Merge "Fix requirements of message_delete_many API"

Browse Source
This commit is contained in:
Jenkins 2016-01-15 16:07:20 +00:00 committed by Gerrit Code Review
commit fb414fc523
2 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
zaqar/api/v1/request.py
View File

@ -294,7 +294,7 @@ class RequestSchema(api.Api):
'message_ids': {'type': 'array'},
'pop': {'type': 'integer'}
},
'required': ['queue_name', 'message_ids'],
'required': ['queue_name'],
}
},
'required': ['action', 'headers', 'body']

20
zaqar/tests/unit/transport/websocket/v2/test_messages.py
View File

@ -514,6 +514,26 @@ class MessagesBaseTest(base.V2Base):
resp = json.loads(send_mock.call_args[0][0])
self.assertEqual(204, resp['headers']['status'])
def test_pop_delete(self):
self._post_messages("kitkat", repeat=5)
action = "message_delete_many"
body = {"queue_name": "kitkat",
"pop_limit": 2}
send_mock = mock.Mock()
self.protocol.sendMessage = send_mock
req = test_utils.create_request(action, body, self.headers)
self.protocol.onMessage(req, False)
resp = json.loads(send_mock.call_args[0][0])
self.assertEqual(200, resp['headers']['status'])
self.assertEqual(2, len(resp['body']['messages']))
self.assertEqual(239, resp['body']['messages'][0]['body'])
self.assertEqual(239, resp['body']['messages'][1]['body'])
def test_get_nonexistent_message_404s(self):
action = "message_get"
body = {"queue_name": "notthere",