carrot.backends.pikachu

class carrot.backends.pikachu.AsyncoreBackend(connection, **kwargs)

class carrot.backends.pikachu.Message(backend, amqp_message, **kwargs)

class carrot.backends.pikachu.SyncBackend(connection, **kwargs)

class Message(backend, amqp_message, **kwargs)

SyncBackend.ack(delivery_tag)

Acknowledge a message by delivery tag.

SyncBackend.cancel(consumer_tag)

Cancel a channel by consumer tag.

SyncBackend.channel

If no channel exists, a new one is requested.

SyncBackend.close()

Close the channel if open.

SyncBackend.close_connection(connection)

Close the AMQP broker connection.

SyncBackend.consume(limit=None)

Returns an iterator that waits for one message at a time.

SyncBackend.declare_consumer(queue, no_ack, callback, consumer_tag, nowait=False)

Declare a consumer.

SyncBackend.establish_connection()

Establish connection to the AMQP broker.

SyncBackend.exchange_declare(exchange, type, durable, auto_delete)

Declare an named exchange.

SyncBackend.flow(active)

Enable/disable flow from peer.

SyncBackend.get(queue, no_ack=False)

Receive a message from a declared queue by name.

Returns:A Message object if a message was received, None otherwise. If None was returned, it probably means there was no messages waiting on the queue.

SyncBackend.message_to_python(raw_message)

Convert encoded message body back to a Python value.

SyncBackend.prepare_message(message_data, delivery_mode, priority=None, content_type=None, content_encoding=None)

Encapsulate data into a AMQP message.

SyncBackend.publish(message, exchange, routing_key, mandatory=None, immediate=None, headers=None)

Publish a message to a named exchange.

SyncBackend.qos(prefetch_size, prefetch_count, apply_global=False)

Request specific Quality of Service.

SyncBackend.queue_bind(queue, exchange, routing_key, arguments={})

Bind queue to an exchange using a routing key.

SyncBackend.queue_declare(queue, durable, exclusive, auto_delete, warn_if_exists=False, arguments=None)

Declare a named queue.

SyncBackend.queue_delete(queue, if_unused=False, if_empty=False)

Delete queue by name.

SyncBackend.queue_exists(queue)

SyncBackend.queue_purge(queue, **kwargs)

Discard all messages in the queue. This will delete the messages and results in an empty queue.

SyncBackend.reject(delivery_tag)

Reject a message by deliver tag.

SyncBackend.requeue(delivery_tag)

Reject and requeue a message by delivery tag.