py-amqp API reference

79 public APIs from py-amqp (celery/py-amqp) — 49 classes, 10 functions, 20 methods. Signatures extracted by static analysis of the actual source.

Repository: celery/py-amqp

Kind	Count
Classes	49
Functions	10
Methods	20

API list

classamqp.abstract_channel.AbstractChannel

Superclass for Connection and Channel.

methodamqp.abstract_channel.AbstractChannel.close()

Close this Channel or Connection.

classamqp.basic_message.Message

A Message for use with the Channel.basic_* methods.

classamqp.channel.Channel

AMQP Channel.

methodamqp.channel.Channel.basic_ack(delivery_tag, multiple=False, argsig='Lb')

Acknowledge one or more messages.

methodamqp.channel.Channel.basic_cancel(consumer_tag, nowait=False, argsig='sb')

End a queue consumer.

methodamqp.channel.Channel.basic_get(queue='', no_ack=False, argsig='Bsb')

Direct access to a queue.

methodamqp.channel.Channel.basic_qos(prefetch_size, prefetch_count, a_global, argsig='lBb')

Specify quality of service.

methodamqp.channel.Channel.basic_recover(requeue=False)

Redeliver unacknowledged messages.

methodamqp.channel.Channel.basic_reject(delivery_tag, requeue, argsig='Lb')

Reject an incoming message.

methodamqp.channel.Channel.close(reply_code=0, reply_text='', method_sig=(0, 0), argsig='BsBB')

Request a channel close.

methodamqp.channel.Channel.collect()

Tear down this object.

methodamqp.channel.Channel.exchange_delete(exchange, if_unused=False, nowait=False, argsig='Bsbb')

Delete an exchange.

methodamqp.channel.Channel.flow(active)

Enable/disable flow from peer.

methodamqp.channel.Channel.open()

Open a channel for use.

methodamqp.channel.Channel.queue_delete(queue='', if_unused=False, if_empty=False, nowait=False, argsig='Bsbbb')

Delete a queue.

methodamqp.channel.Channel.queue_purge(queue='', nowait=False, argsig='Bsb')

Purge a queue.

methodamqp.channel.Channel.tx_commit()

Commit the current transaction.

methodamqp.channel.Channel.tx_rollback()

Abandon the current transaction.

methodamqp.channel.Channel.tx_select()

Select standard transaction mode.

classamqp.connection.Connection

AMQP Connection.

methodamqp.connection.Connection.channel(channel_id=None, callback=None)

Create new channel.

methodamqp.connection.Connection.close(reply_code=0, reply_text='', method_sig=(0, 0), argsig='BsBB')

Request a connection close.

methodamqp.connection.Connection.heartbeat_tick(rate=2)

Send heartbeat packets if necessary.

classamqp.exceptions.AMQPDeprecationWarning

Warning for deprecated things.

classamqp.exceptions.AMQPError

Base class for all AMQP exceptions.

classamqp.exceptions.AMQPNotImplementedError

AMQP Not Implemented Error.

classamqp.exceptions.AccessRefused

AMQP Access Refused Error.

classamqp.exceptions.Blocked

AMQP Connection Blocked Predicate.

classamqp.exceptions.ChannelError

AMQP Channel Error.

classamqp.exceptions.ChannelNotOpen

AMQP Channel Not Open Error.

classamqp.exceptions.ConnectionError

AMQP Connection Error.

classamqp.exceptions.ConnectionForced

AMQP Connection Forced Error.

classamqp.exceptions.ConsumerCancelled

AMQP Consumer Cancelled Predicate.

classamqp.exceptions.ContentTooLarge

AMQP Content Too Large Error.

classamqp.exceptions.FrameError

AMQP Frame Error.

classamqp.exceptions.FrameSyntaxError

AMQP Frame Syntax Error.

classamqp.exceptions.InternalError

AMQP Internal Error.

classamqp.exceptions.InvalidCommand

AMQP Invalid Command Error.

classamqp.exceptions.InvalidPath

AMQP Invalid Path Error.

classamqp.exceptions.IrrecoverableChannelError

Exception class for irrecoverable channel errors.

classamqp.exceptions.IrrecoverableConnectionError

Exception class for irrecoverable connection errors.

classamqp.exceptions.MessageNacked

Message was nacked by broker.

classamqp.exceptions.NoConsumers

AMQP No Consumers Error.

classamqp.exceptions.NotAllowed

AMQP Not Allowed Error.

classamqp.exceptions.NotFound

AMQP Not Found Error.

classamqp.exceptions.PreconditionFailed

AMQP Precondition Failed Error.

classamqp.exceptions.RecoverableChannelError

Exception class for recoverable channel errors.

classamqp.exceptions.RecoverableConnectionError

Exception class for recoverable connection errors.

classamqp.exceptions.ResourceError

AMQP Resource Error.

classamqp.exceptions.ResourceLocked

AMQP Resource Locked Error.

classamqp.exceptions.UnexpectedFrame

AMQP Unexpected Frame.

classamqp.sasl.AMQPLAIN

AMQPLAIN SASL authentication mechanism.

classamqp.sasl.EXTERNAL

EXTERNAL SASL mechanism.

classamqp.sasl.FakeGSSAPI

A no-op SASL mechanism for when gssapi isn't available.

classamqp.sasl.GSSAPI

GSSAPI SASL authentication mechanism.

classamqp.sasl.PLAIN

PLAIN SASL authentication mechanism.

classamqp.sasl.RAW

A generic custom SASL mechanism.

classamqp.sasl.SASL

The base class for all amqp SASL authentication mechanisms.

classamqp.serialization.GenericContent

Abstract base class for AMQP content.

funcamqp.serialization.decode_properties_basic(buf, offset)

Decode basic properties.

funcamqp.serialization.dumps(format, values)

Serialize AMQP arguments.

funcamqp.serialization.loads(format, buf, offset)

Deserialize amqp format.

classamqp.spec.Basic

AMQ Basic class.

classamqp.spec.Channel

AMQ Channel class.

classamqp.spec.Confirm

AMQ Confirm class.

classamqp.spec.Connection

AMQ Connection class.

classamqp.spec.Exchange

AMQ Exchange class.

classamqp.spec.Queue

AMQ Queue class.

classamqp.spec.Tx

AMQ Tx class.

funcamqp.spec.method(method_sig, args=None, content=False)

Create amqp method specification tuple.

classamqp.transport.SSLTransport

Transport that works over SSL.

classamqp.transport.TCPTransport

Transport that deals directly with TCP socket.

funcamqp.transport.Transport(host, connect_timeout=None, ssl=False, **kwargs)

Create transport.

funcamqp.utils.bytes_to_str(s)

Convert bytes to str.

funcamqp.utils.coro(gen)

Decorator to mark generator as a co-routine.

funcamqp.utils.get_logger(logger)

Get logger by name.

funcamqp.utils.set_cloexec(fd, cloexec)

Set flag to close fd after exec.

funcamqp.utils.str_to_bytes(s)

Convert str to bytes.

About this data

These signatures were extracted from the public source of celery/py-amqp using Python's ast module. Argument names, default values, type annotations and return types are taken verbatim from the code. Implementation bodies are never stored. See how it works for details.

Back to all 805 libraries