This Page

Psst... hey. You're reading the latest content, but it might be out of sync with code. You can read Nova 2011.2 docs or all OpenStack docs too.

The nova.fakerabbit Module

Based a bit on the carrot.backeds.queue backend... but a lot better.

class nova.fakerabbit.Backend(connection, **kwargs)

Bases: carrot.backends.base.BaseBackend

cancel(consumer_tag)
consume(limit=None)
declare_consumer(queue, callback, consumer_tag, *args, **kwargs)
exchange_declare(exchange, type, *args, **kwargs)
get(queue, no_ack=False)
prepare_message(message_data, delivery_mode, content_type, content_encoding, **kwargs)

Prepare message for sending.

publish(message, exchange, routing_key, **kwargs)
queue_bind(queue, exchange, routing_key, **kwargs)
queue_declare(queue, **kwargs)
class nova.fakerabbit.Exchange(name, exchange_type)

Bases: object

bind(callback, routing_key)
publish(message, routing_key=None)
class nova.fakerabbit.Message(backend, **kwargs)

Bases: carrot.backends.base.BaseMessage

class nova.fakerabbit.Queue(name)

Bases: object

pop()
push(message, routing_key=None)
size()
nova.fakerabbit.reset_all()