kombu.transport.librabbitmq

librabbitmq 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, channel_max=65535, frame_max=131072, heartbeat=0, lazy=False, **kwargs)

class Channel(connection, channel_id)

class Message(channel, props, info, body)

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

Encapsulate data into a AMQP message.

class Transport.Connection.Message(channel, props, info, body)

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

Transport.close_connection(connection)

Close the AMQP broker connection.

Transport.connection_errors = (<class '_librabbitmq.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.

Transport.eventmap(connection)

Transport.nb_keep_draining = True

Transport.on_poll_init(poller)

Transport.on_poll_start()

Connection

class kombu.transport.librabbitmq.Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, channel_max=65535, frame_max=131072, heartbeat=0, lazy=False, **kwargs)

class Channel(connection, channel_id)

Consumer(*args, **kwargs)

class Message(channel, props, info, body)

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, arguments=None, nowait=False)

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

Connection.Channel.basic_publish(body, exchange='', routing_key='', mandatory=False, immediate=False, **properties)

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)

Declare exchange.

Parameters:auto_delete – Not recommended and so it is ignored.

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

Connection.Channel.flow(active)

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='', arguments=None, nowait=False)

Connection.Channel.recover(requeue=True)

class Connection.Message(channel, props, info, body)

exception MessageStateError

The message has already been acknowledged.

args

message

Connection.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.Message.ack_log_error(logger, errors)

Connection.Message.acknowledged

Set to true if the message has been acknowledged.

Connection.Message.body

Connection.Message.channel

Connection.Message.content_encoding

Connection.Message.content_type

Connection.Message.decode()

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

Connection.Message.delivery_info

Connection.Message.delivery_tag

Connection.Message.headers

Connection.Message.payload

The decoded message body.

Connection.Message.properties

Connection.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.Message.reject_log_error(logger, errors)

Connection.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.callbacks

Connection.channel(channel_id=None)

Connection.channel_max

Connection.close()

Connection.connect()

Establish connection to the broker.

Connection.connected

Connection.drain_events(timeout=None)

Connection.fileno()

File descriptor number.

Connection.frame_max

Connection.heartbeat

Connection.hostname

Connection.password

Connection.port

Connection.reconnect()

Connection.userid

Connection.virtual_host

Channel

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

class Message(channel, props, info, body)

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(channel, props, info, body)