Testing Support

The rejected.testing.AsyncTestCase provides a based class for the easy creation of tests for your consumers. The test cases exposes multiple methods to make it easy to setup a consumer and process messages. It is build on top of tornado.testing.AsyncTestCase which extends unittest.TestCase.

To get started, override the rejected.testing.AsyncTestCase.get_consumer() method.

Next, the rejected.testing.AsyncTestCase.get_settings() method can be overridden to define the settings that are passed into the consumer.

Finally, to invoke your Consumer as if it were receiving a message, the process_message() method should be invoked.

Note

Tests are asynchronous, so each test should be decorated with gen_test().

Example

The following example expects that when the message is processed by the consumer, the consumer will raise a MessageException.

from rejected import consumer, testing

import my_package


class ConsumerTestCase(testing.AsyncTestCase):

    def get_consumer(self):
        return my_package.Consumer

    def get_settings(self):
        return {'remote_url': 'http://foo'}

    @testing.gen_test
    def test_consumer_raises_message_exception(self):
        with self.assertRaises(consumer.MessageException):
            yield self.process_message({'foo': 'bar'})

class rejected.testing.AsyncTestCase(methodName='runTest')

TestCase subclass for testing IOLoop-based asynchronous code.

get_consumer()

Override to return the consumer class for testing.

Return type:class

get_settings()

Override this method to provide settings to the consumer during construction.

Returns:

process_message(*args, **kwargs)

Process a message as if it were being delivered by RabbitMQ. When invoked, an AMQP message will be locally created and passed into the consumer. With using the default values for the method, if you pass in a JSON serializable object, the message body will automatically be JSON serialized.

Parameters:

• message_body (any) – the body of the message to create
• content_type (str) – The mime type
• message_type (str) – identifies the type of message to create
• properties (dict) – AMQP message properties
• exchange (str) – The exchange the message should appear to be from
• routing_key (str) – The message’s routing key

Raises:

rejected.consumer.ConsumerException

Raises:

rejected.consumer.MessageException

Raises:

rejected.consumer.ProcessingException

Returns:

bool

rejected.testing.gen_test(func=None, timeout=None)

Testing equivalent of @gen.coroutine, to be applied to test methods.