FM / v1

/usr/lib/python2.6/site-packages/openstack/tests/unit/message/v1/

/usr/lib/python2.6/site-packages/openstack/tests/unit/message/v1

Name	Size	Mode	Actions
test_claim.py	3364	0644	edit dl rm
test_claim.pyc	3781	0644	edit dl rm
test_message.py	2787	0644	edit dl rm
test_message.pyc	3179	0644	edit dl rm
test_proxy.py	2238	0644	edit dl rm
test_proxy.pyc	3040	0644	edit dl rm
test_queue.py	1735	0644	edit dl rm
test_queue.pyc	2041	0644	edit dl rm
__init__.py	0	0644	edit dl rm
__init__.pyc	165	0644	edit dl rm

Edit: /usr/lib/python2.6/site-packages/openstack/tests/unit/message/v1/test_proxy.py (2238B)

from openstack.message.v1 import _proxy
from openstack.message.v1 import claim
from openstack.message.v1 import message
from openstack.message.v1 import queue
from openstack.tests.unit import test_proxy_base

CLIENT_ID = '3381af92-2b9e-11e3-b191-71861300734c'
QUEUE_NAME = 'test_queue'

class TestMessageProxy(test_proxy_base.TestProxyBase):
    def setUp(self):
        super(TestMessageProxy, self).setUp()
        self.proxy = _proxy.Proxy(self.session)

def test_queue_create_attrs(self):
        self.verify_create(self.proxy.create_queue, queue.Queue)

def test_queue_delete(self):
        self.verify_delete(self.proxy.delete_queue, queue.Queue, False)

def test_queue_delete_ignore(self):
        self.verify_delete(self.proxy.delete_queue, queue.Queue, True)

def test_messages_create(self):
        self._verify2("openstack.message.v1.message.Message.create_messages",
                      self.proxy.create_messages,
                      expected_result="result",
                      method_args=[[]],
                      expected_args=[self.session, []])

def test_messages_claim(self):
        self._verify2("openstack.message.v1.claim.Claim.claim_messages",
                      self.proxy.claim_messages,
                      expected_result="result",
                      method_args=[claim.Claim],
                      expected_args=[self.session, claim.Claim])

def test_message_delete(self):
        self._verify2("openstack.message.v1.message.Message.delete_by_id",
                      self.proxy.delete_message,
                      method_args=[message.Message],
                      expected_args=[self.session, message.Message])

# Licensed under the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. You may obtain # a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the # License for the specific language governing permissions and limitations # under the License. from openstack.message.v1 import _proxy from openstack.message.v1 import claim from openstack.message.v1 import message from openstack.message.v1 import queue from openstack.tests.unit import test_proxy_base CLIENT_ID = '3381af92-2b9e-11e3-b191-71861300734c' QUEUE_NAME = 'test_queue' class TestMessageProxy(test_proxy_base.TestProxyBase): def setUp(self): super(TestMessageProxy, self).setUp() self.proxy = _proxy.Proxy(self.session) def test_queue_create_attrs(self): self.verify_create(self.proxy.create_queue, queue.Queue) def test_queue_delete(self): self.verify_delete(self.proxy.delete_queue, queue.Queue, False) def test_queue_delete_ignore(self): self.verify_delete(self.proxy.delete_queue, queue.Queue, True) def test_messages_create(self): self._verify2("openstack.message.v1.message.Message.create_messages", self.proxy.create_messages, expected_result="result", method_args=[[]], expected_args=[self.session, []]) def test_messages_claim(self): self._verify2("openstack.message.v1.claim.Claim.claim_messages", self.proxy.claim_messages, expected_result="result", method_args=[claim.Claim], expected_args=[self.session, claim.Claim]) def test_message_delete(self): self._verify2("openstack.message.v1.message.Message.delete_by_id", self.proxy.delete_message, method_args=[message.Message], expected_args=[self.session, message.Message])