kombu.transport.librabbitmq

pylibrabbitmq transport.

copyright:

3. 2010 - 2012 by Ask Solem.

license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.librabbitmq.Transport(client, **kwargs)

class Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, **kwargs)

class Channel(connection, channel_id)

class Message(body, props, info, channel)

Transport.Connection.Channel.prepare_message(body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None)

Encapsulate data into a AMQP message.

Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class '_pyrabbitmq.ChannelError'>)

Transport.close_connection(connection)

Close the AMQP broker connection.

Transport.connection_errors = (<class '_pyrabbitmq.ConnectionError'>, <class 'socket.error'>, <type 'exceptions.IOError'>, <type 'exceptions.OSError'>)

Transport.create_channel(connection)

Transport.default_connection_params

Transport.default_port = 5672

Transport.drain_events(connection, **kwargs)

Transport.establish_connection()

Establish connection to the AMQP broker.

Connection

class kombu.transport.librabbitmq.Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, **kwargs)

class Channel(connection, channel_id)

Consumer(*args, **kwargs)

class Message(body, props, info, channel)

exception MessageStateError

The message has already been acknowledged.

args

message

Connection.Channel.Message.ack()

Acknowledge this message as being processed., This will remove the message from the queue.

Raises MessageStateError:  If the message has already been acknowledged/requeued/rejected.

Connection.Channel.Message.ack_log_error(logger, errors)

Connection.Channel.Message.acknowledged

Set to true if the message has been acknowledged.

Connection.Channel.Message.body

Connection.Channel.Message.channel

Connection.Channel.Message.content_encoding

Connection.Channel.Message.content_type

Connection.Channel.Message.decode()

Deserialize the message body, returning the original python structure sent by the publisher.

Connection.Channel.Message.delivery_info

Connection.Channel.Message.delivery_tag

Connection.Channel.Message.headers

Connection.Channel.Message.payload

The decoded message body.

Connection.Channel.Message.properties

Connection.Channel.Message.reject()

Reject this message.

The message will be discarded by the server.

Raises MessageStateError:  If the message has already been acknowledged/requeued/rejected.

Connection.Channel.Message.reject_log_error(logger, errors)

Connection.Channel.Message.requeue()

Reject this message and put it back on the queue.

You must not use this method as a means of selecting messages to process.

Raises MessageStateError:  If the message has already been acknowledged/requeued/rejected.

Connection.Channel.Producer(*args, **kwargs)

Connection.Channel.after_reply_message_received(queue)

reply queue semantics: can be used to delete the queue after transient reply message received.

Connection.Channel.basic_ack(delivery_tag, multiple=False)

Connection.Channel.basic_cancel(consumer_tag, **kwargs)

Connection.Channel.basic_consume(queue='', consumer_tag=None, no_local=False, no_ack=False, exclusive=False, callback=None, nowait=False)

Connection.Channel.basic_get(queue='', no_ack=False)

Connection.Channel.basic_publish(message, exchange='', routing_key='', mandatory=False, immediate=False)

Connection.Channel.basic_qos(prefetch_size=0, prefetch_count=0, _global=False)

Connection.Channel.basic_reject(delivery_tag, requeue=True)

Connection.Channel.close()

Connection.Channel.exchange_declare(exchange='', type='direct', passive=False, durable=False, auto_delete=False, arguments=None, nowait=False)

Connection.Channel.exchange_delete(exchange='', if_unused=False)

Connection.Channel.flow(enabled)

Connection.Channel.is_open = False

Connection.Channel.list_bindings()

Connection.Channel.no_ack_consumers = None

Connection.Channel.prepare_message(body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None)

Encapsulate data into a AMQP message.

Connection.Channel.queue_bind(queue='', exchange='', routing_key='', arguments=None, nowait=False)

Connection.Channel.queue_declare(queue='', passive=False, durable=False, exclusive=False, auto_delete=False, arguments=None, nowait=False)

Connection.Channel.queue_delete(queue='', if_unused=False, if_empty=False)

Connection.Channel.queue_purge(queue, nowait=False)

Connection.Channel.queue_unbind(queue='', exchange='', binding_key='', nowait=False)

Connection.channel(channel_id=None)

Connection.channel_max = 65535

Connection.channels = {}

Connection.close()

Connection.drain_events(timeout=None)

Connection.frame_max = 131072

Connection.heartbeat = 0

Connection.reconnect()

Channel

class kombu.transport.librabbitmq.Channel(connection, channel_id)

class Message(body, props, info, channel)

Channel.prepare_message(body, priority=None, content_type=None, content_encoding=None, headers=None, properties=None)

Encapsulate data into a AMQP message.

Message

class kombu.transport.librabbitmq.Message(body, props, info, channel)