kombu.transport.pika

Pika transport.

copyright:

3. 2009 - 2012 by Ask Solem.

license:

BSD, see LICENSE for more details.

Transport

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

class Connection(client, *args, **kwargs)

class Channel(connection, channel_number, transport=None)

class Message(channel, amqp_message, **kwargs)

Transport.Connection.Channel.basic_consume(queue, no_ack=False, consumer_tag=None, callback=None, nowait=False)

Transport.Connection.Channel.basic_get(queue, no_ack)

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

Transport.Connection.Channel.basic_qos(prefetch_size, prefetch_count, a_global=False)

Transport.Connection.Channel.channel_id

Transport.Connection.Channel.close(*args)

Transport.Connection.Channel.message_to_python(raw_message)

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

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

Transport.Connection.channel()

Transport.Connection.close(*args)

Transport.Connection.drain_events(timeout=None)

class Transport.Message(channel, amqp_message, **kwargs)

Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class 'pika.exceptions.ChannelClosed'>, <class 'pika.exceptions.DuplicateConsumerTag'>, <class 'pika.exceptions.UnknownConsumerTag'>, <class 'pika.exceptions.ProtocolSyntaxError'>)

Transport.close_connection(connection)

Close the AMQP broker connection.

Transport.connection_errors = (<class 'socket.error'>, <class 'pika.exceptions.ConnectionClosed'>, <class 'pika.exceptions.ChannelClosed'>, <class 'pika.exceptions.LoginError'>, <class 'pika.exceptions.NoFreeChannels'>, <class 'pika.exceptions.DuplicateConsumerTag'>, <class 'pika.exceptions.UnknownConsumerTag'>, <class 'pika.exceptions.RecursiveOperationDetected'>, <class 'pika.exceptions.ProtocolSyntaxError'>)

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.pika2.Connection(client, *args, **kwargs)

class Channel(connection, channel_number, transport=None)

class Message(channel, amqp_message, **kwargs)

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

Connection.Channel.basic_get(queue, no_ack)

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

Connection.Channel.basic_qos(prefetch_size, prefetch_count, a_global=False)

Connection.Channel.channel_id

Connection.Channel.close(*args)

Connection.Channel.message_to_python(raw_message)

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

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

Connection.channel()

Connection.close(*args)

Connection.drain_events(timeout=None)

Channel

class kombu.transport.pika2.Channel(connection, channel_number, transport=None)

class Message(channel, amqp_message, **kwargs)

Channel.basic_consume(queue, no_ack=False, consumer_tag=None, callback=None, nowait=False)

Channel.basic_get(queue, no_ack)

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

Channel.basic_qos(prefetch_size, prefetch_count, a_global=False)

Channel.channel_id

Channel.close(*args)

Channel.message_to_python(raw_message)

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

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

Message

class kombu.transport.pika2.Message(channel, amqp_message, **kwargs)