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()