Upgrading kombu 1 to 2
Unknown1.5.1 → 2.5.16
Fetching 48 releases from GitHub…0 / 48
UnknownUpgrade verdict
DepDelta is still reading the notes for this range, so breaking changes can't be ruled out yet.
In plain terms
- DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
- This page updates as the notes come in.
Must act Still reading release notes
DepDelta is still reading the release notes in this range. This updates as they come in.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
export BrokerConnection - added:
export Connection - added:
export Consumer - added:
export Exchange - added:
export Producer - added:
export Queue - added:
export binding - added:
export connections - added:
export disable_insecure_serializers - added:
export enable_insecure_serializers - added:
export eventloop - added:
export parse_url - added:
export producers - added:
export uuid - added:
variable STATICA_HACK - added:
variable package
- added:
field MaybeChannelBound.can_cache_declaration
- added:
method LamportClock.sort_heap(h)
- removed:
function entry_to_queue(queue, **options) - removed:
variable declared_entities - changed:
class Broadcast(entity.Queue) → class Broadcast(Queue) - changed:
function maybe_declare(entity, channel) → function maybe_declare(entity, channel=…, retry=…, **retry_policy) - added:
export uuid - added:
function collect_replies(conn, channel, queue, *args, **kwargs) - added:
function drain_consumer(consumer, limit=…, timeout=…, callbacks=…) - added:
function eventloop(conn, limit=…, timeout=…, ignore_timeouts=…) - added:
function insured(pool, fun, args, kwargs, errback=…, on_revive=…, **opts) - added:
function ipublish(pool, fun, args=…, kwargs=…, errback=…, on_revive=…, **retry_policy) - added:
function isend_reply(pool, exchange, req, msg, props, **retry_policy) - added:
function itermessages(conn, channel, queue, limit=…, timeout=…, Consumer=…, callbacks=…, **kwargs) - added:
function send_reply(exchange, req, msg, producer=…, **props)
- removed:
class ConsumerSet(messaging.Consumer) - removed:
constructor ConsumerSet(connection, from_dict=…, consumers=…, callbacks=…, **kwargs) - removed:
method ConsumerSet.add_consumer(consumer) - removed:
method ConsumerSet.add_consumer_from_dict(queue, **options) - removed:
method ConsumerSet.close() - removed:
method ConsumerSet.discard_all() - removed:
method ConsumerSet.iterconsume(limit=…, no_ack=…) - removed:
method ConsumerSet.revive(channel)
- removed:
class BrokerConnection(object) - removed:
class PoolChannelContext(object) - removed:
class Resource(object) - removed:
constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, transport_options=…, login_method=…, **kwargs) - removed:
constructor PoolChannelContext(pool, block=…) - removed:
constructor Resource(limit=…, preload=…) - removed:
field BrokerConnection.URI_FORMAT - removed:
field BrokerConnection.close - removed:
field BrokerConnection.connect_timeout - removed:
field BrokerConnection.create_backend - removed:
field BrokerConnection.port - removed:
field BrokerConnection.skip_uri_transports - removed:
field BrokerConnection.virtual_host - removed:
function parse_url(url) - removed:
method BrokerConnection.ChannelPool(limit=…, preload=…) - removed:
method BrokerConnection.Consumer(queues=…, channel=…, *args, **kwargs) - removed:
method BrokerConnection.Pool(limit=…, preload=…) - removed:
method BrokerConnection.Producer(channel=…, *args, **kwargs) - removed:
method BrokerConnection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - removed:
method BrokerConnection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - removed:
method BrokerConnection.as_uri(include_password=…) - removed:
method BrokerConnection.autoretry(fun, channel=…, **ensure_options) - removed:
method BrokerConnection.channel() - removed:
method BrokerConnection.clone(**kwargs) - removed:
method BrokerConnection.connect() - removed:
method BrokerConnection.create_transport() - removed:
method BrokerConnection.drain_events(**kwargs) - removed:
method BrokerConnection.ensure(obj, fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, on_revive=…) - removed:
method BrokerConnection.ensure_connection(errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - removed:
method BrokerConnection.get_transport_cls() - removed:
method BrokerConnection.info() - removed:
method BrokerConnection.maybe_close_channel(channel) - removed:
method BrokerConnection.release() - removed:
method BrokerConnection.revive(new_channel) - removed:
method Resource.acquire(*args, **kwargs) - removed:
method Resource.close_resource(resource) - removed:
method Resource.force_close_all() - removed:
method Resource.prepare(resource) - removed:
method Resource.release(resource) - removed:
method Resource.release_resource(resource) - removed:
method Resource.replace(resource) - removed:
method Resource.setup() - removed:
property BrokerConnection.channel_errors - removed:
property BrokerConnection.connected - removed:
property BrokerConnection.connection - removed:
property BrokerConnection.connection_errors - removed:
property BrokerConnection.default_channel - removed:
property BrokerConnection.host - removed:
property BrokerConnection.transport - removed:
variable Connection - removed:
variable URI_FORMAT - added:
class Connection(object) - added:
constructor Connection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, transport_options=…, login_method=…, uri_prefix=…, heartbeat=…, failover_strategy=…, alternates=…, **kwargs) - added:
field Connection.close - added:
field Connection.connect_timeout - added:
field Connection.create_backend - added:
field Connection.cycle - added:
field Connection.declared_entities - added:
field Connection.failover_strategy - added:
field Connection.heartbeat - added:
field Connection.hostname - added:
field Connection.login_method - added:
field Connection.more_to_read - added:
field Connection.password - added:
field Connection.port - added:
field Connection.ssl - added:
field Connection.transport_options - added:
field Connection.uri_prefix - added:
field Connection.userid - added:
field Connection.virtual_host - added:
method Connection.ChannelPool(limit=…, preload=…) - added:
method Connection.Consumer(queues=…, channel=…, *args, **kwargs) - added:
method Connection.Pool(limit=…, preload=…) - added:
method Connection.Producer(channel=…, *args, **kwargs) - added:
method Connection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - added:
method Connection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - added:
method Connection.as_uri(include_password=…) - added:
method Connection.autoretry(fun, channel=…, **ensure_options) - added:
method Connection.channel() - added:
method Connection.clone(**kwargs) - added:
method Connection.collect(socket_timeout=…) - added:
method Connection.completes_cycle(retries) - added:
method Connection.connect() - added:
method Connection.create_transport() - added:
method Connection.drain_events(**kwargs) - added:
method Connection.drain_nowait(*args, **kwargs) - added:
method Connection.ensure(obj, fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, on_revive=…) - added:
method Connection.ensure_connection(errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, callback=…) - added:
method Connection.get_manager(*args, **kwargs) - added:
method Connection.get_transport_cls() - added:
method Connection.heartbeat_check(rate=…) - added:
method Connection.info() - added:
method Connection.maybe_close_channel(channel) - added:
method Connection.maybe_switch_next() - added:
method Connection.release() - added:
method Connection.revive(new_channel) - added:
method Connection.switch(url) - added:
method ConnectionPool.collect_resource(resource, socket_timeout=…) - added:
property Connection.channel_errors - added:
property Connection.connected - added:
property Connection.connection - added:
property Connection.connection_errors - added:
property Connection.default_channel - added:
property Connection.eventmap - added:
property Connection.host - added:
property Connection.is_evented - added:
property Connection.manager - added:
property Connection.recoverable_channel_errors - added:
property Connection.recoverable_connection_errors - added:
property Connection.supports_heartbeats - added:
property Connection.transport
- removed:
method Queue.unbind() - removed:
variable DELIVERY_MODES - removed:
variable PERSISTENT_DELIVERY_MODE - removed:
variable TRANSIENT_DELIVERY_MODE - changed:
constructor Queue(name=…, exchange=…, routing_key=…, channel=…, **kwargs) → constructor Queue(name=…, exchange=…, routing_key=…, channel=…, bindings=…, on_declared=…, **kwargs) - changed:
method Exchange.declare(nowait=…) → method Exchange.declare(nowait=…, passive=…) - changed:
method Queue.get(no_ack=…) → method Queue.get(no_ack=…, accept=…) - added:
field Exchange.passive - added:
method Exchange.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…, **kwargs) - added:
method Exchange.unbind_from(source=…, routing_key=…, nowait=…, arguments=…) - added:
method Queue.bind(channel) - added:
method Queue.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…) - added:
method Queue.queue_unbind(arguments=…, nowait=…) - added:
method Queue.unbind_from(exchange=…, routing_key=…, arguments=…, nowait=…) - added:
property Exchange.can_cache_declaration - added:
property Queue.can_cache_declaration - added:
static method Queue.from_dict(queue, **options)
- removed:
class TimeoutError(Exception) - changed:
class LimitExceeded(Exception) → class LimitExceeded(KombuError) - changed:
class MessageStateError(Exception) → class MessageStateError(KombuError) - changed:
class NotBoundError(Exception) → class NotBoundError(KombuError) - changed:
class StdChannelError(Exception) → class StdChannelError(KombuError) - changed:
class VersionMismatch(Exception) → class VersionMismatch(KombuError) - added:
class SerializerNotInstalled(KombuError) - added:
class StdConnectionError(KombuError) - added:
variable TimeoutError
- added:
class LogMixin(object) - added:
function get_loglevel(level) - added:
function setup_logging(loglevel=…, logfile=…) - added:
method LogMixin.annotate(text) - added:
method LogMixin.critical(*args, **kwargs) - added:
method LogMixin.debug(*args, **kwargs) - added:
method LogMixin.error(*args, **kwargs) - added:
method LogMixin.get_logger() - added:
method LogMixin.get_loglevel(level) - added:
method LogMixin.info(*args, **kwargs) - added:
method LogMixin.is_enabled_for(level) - added:
method LogMixin.log(severity, *args, **kwargs) - added:
method LogMixin.warn(*args, **kwargs) - added:
property LogMixin.logger - added:
property LogMixin.logger_name - added:
variable LOG_LEVELS
- removed:
variable Exchange - removed:
variable Queue - changed:
constructor Consumer(channel, queues, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…) → constructor Consumer(channel, queues=…, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…, on_message=…, accept=…) - changed:
method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…, **properties) → method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…, retry=…, retry_policy=…, declare=…, **properties) - added:
export Exchange - added:
export Queue - added:
field Consumer.accept - added:
field Consumer.on_message - added:
method Consumer.add_queue_from_dict(queue, **options) - added:
method Producer.maybe_declare(entity, retry=…, **retry_policy) - added:
property Consumer.connection - added:
property Producer.connection
- removed:
method ConsumerMixin.error(msg, *args) - removed:
method ConsumerMixin.info(msg, *args) - changed:
method ConsumerMixin.on_consume_ready(connection, channel) → method ConsumerMixin.on_consume_ready(connection, channel, consumers, **kwargs) - changed:
method ConsumerMixin.run() → method ConsumerMixin.run(_tokens=…) - added:
method ConsumerMixin.establish_connection() - added:
method ConsumerMixin.maybe_conn_error(fun) - added:
method ConsumerMixin.on_consume_end(connection, channel) - added:
method ConsumerMixin.on_decode_error(message, exc) - added:
property ConsumerMixin.channel_errors - added:
property ConsumerMixin.connection_errors
- removed:
method Node.dispatch_from_message(message) - changed:
constructor Mailbox(namespace, type=…, connection=…) → constructor Mailbox(namespace, type=…, connection=…, clock=…, accept=…) - changed:
method Mailbox.get_reply_queue(ticket) → method Mailbox.get_reply_queue() - changed:
method Node.dispatch(method, arguments=…, reply_to=…) → method Node.dispatch(method, arguments=…, reply_to=…, ticket=…, **kwargs) - changed:
method Node.handle_message(body, message) → method Node.handle_message(body, message=…) - changed:
method Node.reply(data, exchange, routing_key, **kwargs) → method Node.reply(data, exchange, routing_key, ticket, **kwargs) - added:
field Node.dispatch_from_message - added:
property Mailbox.oid - added:
property Mailbox.reply_queue
- removed:
method ProducerPool.Producer(connection) - added:
field ProducerPool.Producer - added:
method ProducerPool.close_resource(resource)
- removed:
class SerializerNotInstalled(StandardError) - removed:
class SerializerRegistry(object) - removed:
constructor SerializerRegistry() - removed:
function raw_encode(data) - removed:
function register_json() - removed:
function register_msgpack() - removed:
function register_pickle() - removed:
function register_yaml() - removed:
method SerializerRegistry.decode(data, content_type, content_encoding, force=…) - removed:
method SerializerRegistry.disable(name) - removed:
method SerializerRegistry.encode(data, serializer=…) - removed:
method SerializerRegistry.register(name, encoder, decoder, content_type, content_encoding=…) - removed:
method SerializerRegistry.unregister(name) - removed:
variable bytes_type - removed:
variable cpickle - removed:
variable registry
- removed:
class SimpleBase(object) - removed:
constructor SimpleBase(channel, producer, consumer, no_ack=…, channel_autoclose=…) - removed:
method SimpleBase.clear() - removed:
method SimpleBase.close() - removed:
method SimpleBase.get(block=…, timeout=…) - removed:
method SimpleBase.get_nowait() - removed:
method SimpleBase.put(message, serializer=…, headers=…, compression=…, routing_key=…, **kwargs) - removed:
method SimpleBase.qsize()
- removed:
function blocking(fun, *args, **kwargs) - removed:
function select_blocking_method(type)
- removed:
export rpartition - removed:
variable DEFAULT_TRANSPORT - removed:
variable MISSING_LIB - added:
export symbol_by_name - added:
function supports_librabbitmq()
- added:
field Channel.default_visibility_timeout - added:
field Channel.default_wait_time_seconds - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.wait_time_seconds - added:
function maybe_int(x) - added:
property Channel.queue_name_prefix - added:
property Channel.wait_time_seconds - added:
variable BOTO_VERSION - added:
variable W_LONG_POLLING
- added:
class Channel(_Channel, base.StdChannel) - added:
class Connection(amqp.Connection) - added:
class Message(base.Message) - added:
class SSLError(Exception) - added:
class SSLTransport(transport.SSLTransport) - added:
class TCPTransport(transport.TCPTransport) - added:
class Transport(base.Transport) - added:
constructor Channel(*args, **kwargs) - added:
constructor Connection(*args, **kwargs) - added:
constructor Message(channel, msg, **kwargs) - added:
constructor SSLTransport(host, connect_timeout, ssl) - added:
constructor Transport(client, **kwargs) - added:
field Channel.Message - added:
field Channel.events - added:
field Transport.Connection - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.nb_keep_draining - added:
field Transport.supports_ev - added:
method Channel.basic_cancel(consumer_tag, **kwargs) - added:
method Channel.basic_consume(*args, **kwargs) - added:
method Channel.close() - added:
method Channel.message_to_python(raw_message) - added:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Connection.channel(channel_id=…) - added:
method Connection.drain_events(timeout=…) - added:
method Connection.read_timeout(timeout=…) - added:
method SSLTransport.read_frame() - added:
method TCPTransport.read_frame() - added:
method Transport.close_connection(connection) - added:
method Transport.create_channel(connection) - added:
method Transport.drain_events(connection, **kwargs) - added:
method Transport.establish_connection() - added:
method Transport.eventmap(connection) - added:
method Transport.get_manager(*args, **kwargs) - added:
method Transport.is_alive(connection) - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
method Transport.verify_connection(connection) - added:
property Transport.default_connection_params - added:
variable DEFAULT_PORT - added:
variable HAS_MSG_PEEK
- removed:
field Message.body - removed:
field Message.channel - removed:
field Message.content_encoding - removed:
field Message.content_type - removed:
field Message.delivery_info - removed:
field Message.delivery_tag - removed:
field Message.headers - removed:
field Message.properties - removed:
method StdChannel.list_bindings() - changed:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, **kwargs) → constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, accept=…, **kwargs) - added:
class Management(object) - added:
constructor Management(transport) - added:
field Transport.Management - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.nb_keep_draining - added:
field Transport.supports_ev - added:
field Transport.supports_heartbeats - added:
method Management.get_bindings() - added:
method Message.ack_log_error(logger, errors) - added:
method Message.reject_log_error(logger, errors) - added:
method StdChannel.get_bindings() - added:
method Transport.driver_version() - added:
method Transport.eventmap(connection) - added:
method Transport.get_manager(*args, **kwargs) - added:
method Transport.heartbeat_check(connection, rate=…) - added:
method Transport.on_poll_empty() - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
property Transport.manager
- removed:
field Transport.interval - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
method Transport.driver_version()
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
field Channel.view_created - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
function create_message_view(db) - added:
method Transport.driver_version() - added:
property Channel.client - added:
variable DEFAULT_DATABASE - added:
variable DEFAULT_PORT
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
export Queue - added:
export StdChannelError - added:
export StdConnectionError - added:
export virtual - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
method Channel.basic_consume(queue, *args, **kwargs) - added:
method Channel.refresh_connection() - added:
method Transport.driver_version() - added:
variable POLLING_INTERVAL - added:
variable VERSION
- added:
class Command(BaseCommand) - added:
field Command.requires_model_validation - added:
function pluralize(desc, value) - added:
method Command.handle(*args, **options)
- added:
class MessageManager(models.Manager) - added:
class QueueManager(models.Manager) - added:
field MessageManager.cleanup_every - added:
function select_for_update(qs) - added:
method MessageManager.cleanup() - added:
method MessageManager.connection_for_write() - added:
method MessageManager.pop() - added:
method QueueManager.fetch(queue_name) - added:
method QueueManager.publish(queue_name, payload) - added:
method QueueManager.purge(queue_name) - added:
method QueueManager.size(queue_name) - added:
variable connections - added:
variable router
- added:
class Message(models.Model) - added:
class Message.Meta - added:
class Queue(models.Model) - added:
class Queue.Meta - added:
field Message.Meta.db_table - added:
field Message.Meta.verbose_name - added:
field Message.Meta.verbose_name_plural - added:
field Message.objects - added:
field Message.payload - added:
field Message.queue - added:
field Message.sent_at - added:
field Message.visible - added:
field Queue.Meta.db_table - added:
field Queue.Meta.verbose_name - added:
field Queue.Meta.verbose_name_plural - added:
field Queue.name - added:
field Queue.objects
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
function lock(file, flags) - added:
function unlock(file) - added:
method Transport.driver_version() - added:
property Channel.data_folder_in - added:
property Channel.data_folder_out - added:
property Channel.processed_folder - added:
property Channel.store_processed - added:
property Channel.transport_options - added:
variable LOCK_EX - added:
variable LOCK_NB - added:
variable LOCK_SH - added:
variable VERSION
- removed:
method Channel.message_to_python(raw_message) - changed:
constructor Message(channel, message, **kwargs) → constructor Message(channel, props, info, body) - added:
field Connection.Message - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.nb_keep_draining - added:
field Transport.supports_ev - added:
method Transport.driver_version() - added:
method Transport.eventmap(connection) - added:
method Transport.get_manager(*args, **kwargs) - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
method Transport.verify_connection(connection) - added:
variable NO_SSL_ERROR
- added:
field Transport.driver_name - added:
field Transport.driver_type - added:
method Transport.driver_version()
- removed:
field Transport.interval - added:
constructor Channel(*vargs, **kwargs) - added:
field Channel.supports_fanout - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
method Channel.get_table(exchange) - added:
method Channel.queue_delete(queue, **kwargs) - added:
method Transport.driver_version()
- added:
class Channel(amqp.Channel, base.StdChannel) - added:
class Connection(amqp.Connection) - added:
class Message(base.Message) - added:
class Transport(base.Transport) - added:
constructor Message(channel, msg, **kwargs) - added:
constructor Transport(client, **kwargs) - added:
field Channel.Message - added:
field Connection.Channel - added:
field Transport.Connection - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.nb_keep_draining - added:
field Transport.supports_ev - added:
field Transport.supports_heartbeats - added:
method Channel.message_to_python(raw_message) - added:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Transport.close_connection(connection) - added:
method Transport.create_channel(connection) - added:
method Transport.drain_events(connection, **kwargs) - added:
method Transport.driver_version() - added:
method Transport.establish_connection() - added:
method Transport.eventmap(connection) - added:
method Transport.get_manager(*args, **kwargs) - added:
method Transport.heartbeat_check(connection, rate=…) - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
property Transport.default_connection_params - added:
variable DEFAULT_PORT
- removed:
class Channel(_Channel, base.StdChannel) - removed:
class Connection(amqp.Connection) - removed:
class Message(base.Message) - removed:
class SSLError(Exception) - removed:
class Transport(base.Transport) - removed:
constructor Channel(*args, **kwargs) - removed:
constructor Connection(*args, **kwargs) - removed:
constructor Message(channel, msg, **kwargs) - removed:
constructor Transport(client, **kwargs) - removed:
field Channel.Message - removed:
field Channel.events - removed:
field Transport.Connection - removed:
field Transport.channel_errors - removed:
field Transport.connection_errors - removed:
field Transport.default_port - removed:
method Channel.basic_cancel(consumer_tag, **kwargs) - removed:
method Channel.basic_consume(*args, **kwargs) - removed:
method Channel.close() - removed:
method Channel.message_to_python(raw_message) - removed:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - removed:
method Connection.channel(channel_id=…) - removed:
method Connection.drain_events(allowed_methods=…, timeout=…) - removed:
method Connection.read_timeout(timeout=…) - removed:
method Connection.wait_multi(channels, allowed_methods=…, timeout=…) - removed:
method Transport.close_connection(connection) - removed:
method Transport.create_channel(connection) - removed:
method Transport.drain_events(connection, **kwargs) - removed:
method Transport.establish_connection() - removed:
method Transport.verify_connection(connection) - removed:
property Transport.default_connection_params - removed:
variable DEFAULT_PORT
- removed:
class Channel(virtual.Channel) - removed:
class Transport(virtual.Transport) - removed:
field Channel.view_created - removed:
field Transport.Channel - removed:
field Transport.channel_errors - removed:
field Transport.connection_errors - removed:
field Transport.default_port - removed:
field Transport.interval - removed:
function create_message_view(db) - removed:
property Channel.client - removed:
variable DEFAULT_DATABASE - removed:
variable DEFAULT_PORT
- removed:
class AsyncoreConnection(asyncore_adapter.AsyncoreConnection) - removed:
class AsyncoreTransport(SyncTransport) - removed:
class BlockingConnection(blocking_adapter.BlockingConnection) - removed:
class Channel(channel.Channel, base.StdChannel) - removed:
class Message(base.Message) - removed:
class SyncTransport(base.Transport) - removed:
constructor AsyncoreConnection(client, *args, **kwargs) - removed:
constructor BlockingConnection(client, *args, **kwargs) - removed:
constructor Message(channel, amqp_message, **kwargs) - removed:
constructor SyncTransport(client, **kwargs) - removed:
field AsyncoreConnection.Super - removed:
field AsyncoreTransport.Connection - removed:
field BlockingConnection.Super - removed:
field Channel.Message - removed:
field SyncTransport.Connection - removed:
field SyncTransport.Message - removed:
field SyncTransport.channel_errors - removed:
field SyncTransport.connection_errors - removed:
field SyncTransport.default_port - removed:
method AsyncoreConnection.channel() - removed:
method AsyncoreConnection.close() - removed:
method AsyncoreConnection.ensure_drain_events(timeout=…) - removed:
method AsyncoreConnection.on_data_available(buf) - removed:
method BlockingConnection.channel() - removed:
method BlockingConnection.close() - removed:
method BlockingConnection.ensure_drain_events(timeout=…) - removed:
method Channel.basic_ack(delivery_tag) - removed:
method Channel.basic_consume(queue, no_ack=…, consumer_tag=…, callback=…, nowait=…) - removed:
method Channel.basic_get(queue, no_ack) - removed:
method Channel.basic_publish(message, exchange, routing_key, mandatory=…, immediate=…) - removed:
method Channel.close() - removed:
method Channel.message_to_python(raw_message) - removed:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - removed:
method Channel.queue_purge(queue=…, nowait=…) - removed:
method SyncTransport.close_connection(connection) - removed:
method SyncTransport.create_channel(connection) - removed:
method SyncTransport.drain_events(connection, **kwargs) - removed:
method SyncTransport.establish_connection() - removed:
property Channel.channel_id - removed:
property SyncTransport.default_connection_params - removed:
variable BASIC_PROPERTIES - removed:
variable DEFAULT_PORT
- removed:
class Channel(virtual.Channel) - removed:
class MultiChannelPoller(object) - removed:
class Transport(virtual.Transport) - removed:
constructor Channel(*args, **kwargs) - removed:
constructor MultiChannelPoller() - removed:
constructor Transport(*args, **kwargs) - removed:
field Channel.keyprefix_queue - removed:
field Channel.sep - removed:
field Channel.supports_fanout - removed:
field MultiChannelPoller.eventflags - removed:
field Transport.Channel - removed:
field Transport.default_port - removed:
field Transport.interval - removed:
method Channel.basic_cancel(consumer_tag) - removed:
method Channel.basic_consume(queue, *args, **kwargs) - removed:
method Channel.close() - removed:
method Channel.get_table(exchange) - removed:
method MultiChannelPoller.add(channel) - removed:
method MultiChannelPoller.close() - removed:
method MultiChannelPoller.discard(channel) - removed:
method MultiChannelPoller.get(timeout=…) - removed:
property Channel.active_queues - removed:
property Channel.client - removed:
property Channel.subclient - removed:
variable DEFAULT_DB - removed:
variable DEFAULT_PORT
- added:
class Channel(virtual.Channel) - added:
class MultiChannelPoller(object) - added:
class MutexHeld(Exception) - added:
class QoS(virtual.QoS) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
constructor MultiChannelPoller() - added:
constructor QoS(*args, **kwargs) - added:
constructor Transport(*args, **kwargs) - added:
field Channel.QoS - added:
field Channel.ack_emulation - added:
field Channel.from_transport_options - added:
field Channel.keyprefix_queue - added:
field Channel.max_connections - added:
field Channel.priority_steps - added:
field Channel.sep - added:
field Channel.socket_timeout - added:
field Channel.supports_fanout - added:
field Channel.unacked_index_key - added:
field Channel.unacked_key - added:
field Channel.unacked_mutex_expire - added:
field Channel.unacked_mutex_key - added:
field Channel.unacked_restore_limit - added:
field Channel.visibility_timeout - added:
field MultiChannelPoller.eventflags - added:
field QoS.restore_at_shutdown - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
field Transport.supports_ev - added:
function Mutex(client, name, expire) - added:
function register_after_fork(*args, **kwargs) - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, *args, **kwargs) - added:
method Channel.close() - added:
method Channel.conn_or_acquire(client=…) - added:
method Channel.get_table(exchange) - added:
method Channel.priority(n) - added:
method MultiChannelPoller.add(channel) - added:
method MultiChannelPoller.close() - added:
method MultiChannelPoller.discard(channel) - added:
method MultiChannelPoller.get(timeout=…) - added:
method MultiChannelPoller.handle_event(fileno, event) - added:
method MultiChannelPoller.on_poll_empty() - added:
method MultiChannelPoller.on_poll_init(poller) - added:
method MultiChannelPoller.on_poll_start() - added:
method QoS.ack(delivery_tag) - added:
method QoS.append(message, delivery_tag) - added:
method QoS.pipe_or_acquire(pipe=…) - added:
method QoS.reject(delivery_tag, requeue=…) - added:
method QoS.restore_by_tag(tag, client=…) - added:
method QoS.restore_unacked() - added:
method QoS.restore_visible(start=…, num=…, interval=…) - added:
method Transport.driver_version() - added:
method Transport.handle_event(fileno, event) - added:
method Transport.on_poll_empty() - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
property Channel.active_queues - added:
property Channel.client - added:
property Channel.pool - added:
property Channel.subclient - added:
property MultiChannelPoller.fds - added:
property QoS.unacked_index_key - added:
property QoS.unacked_key - added:
property QoS.unacked_mutex_expire - added:
property QoS.unacked_mutex_key - added:
property QoS.visibility_timeout - added:
variable DEFAULT_DB - added:
variable DEFAULT_PORT - added:
variable NO_ROUTE_ERROR - added:
variable PRIORITY_STEPS - added:
variable logger - added:
variable redis
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
export Message - added:
export Queue - added:
export StdChannelError - added:
export StdConnectionError - added:
export metadata - added:
export virtual - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
method Transport.driver_version() - added:
property Channel.session - added:
variable VERSION
- added:
class Message(ModelBase) - added:
class Queue(ModelBase) - added:
constructor Message(payload, queue) - added:
constructor Queue(name) - added:
field Message.id - added:
field Message.payload - added:
field Message.queue_id - added:
field Message.sent_at - added:
field Message.version - added:
field Message.visible - added:
field Queue.id - added:
field Queue.messages - added:
field Queue.name - added:
variable ModelBase - added:
variable metadata
- removed:
field Transport.interval - changed:
method Channel.basic_get(queue, **kwargs) → method Channel.basic_get(queue, no_ack=…, **kwargs) - changed:
method Channel.exchange_declare(exchange, type=…, durable=…, auto_delete=…, arguments=…, nowait=…) → method Channel.exchange_declare(exchange=…, type=…, durable=…, auto_delete=…, arguments=…, nowait=…, passive=…) - changed:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) → method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - changed:
method Channel.queue_bind(queue, exchange, routing_key, arguments=…, **kwargs) → method Channel.queue_bind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - changed:
method Channel.queue_declare(queue, passive=…, auto_delete=…, **kwargs) → method Channel.queue_declare(queue=…, passive=…, **kwargs) - changed:
method Channel.typeof(exchange) → method Channel.typeof(exchange, default=…) - added:
class Management(base.Management) - added:
constructor Management(transport) - added:
export uuid - added:
field Channel.QoS - added:
field QoS.restore_at_shutdown - added:
field Transport.Management - added:
method BrokerState.clear() - added:
method Channel.exchange_bind(destination, source=…, routing_key=…, nowait=…, arguments=…) - added:
method Channel.exchange_unbind(destination, source=…, routing_key=…, nowait=…, arguments=…) - added:
method Channel.queue_unbind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - added:
method Management.close() - added:
method Management.get_bindings() - added:
method QoS.restore_visible(start=…, num=…, interval=…)
- added:
class Channel(virtual.Channel) - added:
class Client(object) - added:
class MultiChannelPoller(object) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
constructor Client(uri=…, port=…, hwm=…, swap_size=…, enable_sink=…, context=…) - added:
constructor MultiChannelPoller() - added:
constructor Transport(*args, **kwargs) - added:
field Channel.Client - added:
field Channel.enable_sink - added:
field Channel.from_transport_options - added:
field Channel.hwm - added:
field Channel.port_incr - added:
field Channel.swap_size - added:
field MultiChannelPoller.eventflags - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.nb_keep_draining - added:
field Transport.polling_interval - added:
field Transport.supports_ev - added:
method Channel.close() - added:
method Client.close() - added:
method Client.connect(endpoint) - added:
method Client.get(queue=…, timeout=…) - added:
method Client.put(queue, message, **kwargs) - added:
method MultiChannelPoller.add(channel) - added:
method MultiChannelPoller.close() - added:
method MultiChannelPoller.discard(channel) - added:
method MultiChannelPoller.get(timeout=…) - added:
method MultiChannelPoller.handle_event(fileno, event) - added:
method MultiChannelPoller.on_poll_start() - added:
method Transport.close_connection(connection) - added:
method Transport.drain_events(connection, timeout=…) - added:
method Transport.driver_version() - added:
method Transport.establish_connection() - added:
method Transport.handle_event(fileno, event) - added:
method Transport.on_poll_init(poller) - added:
method Transport.on_poll_start() - added:
property Channel.client - added:
property Client.connection - added:
property MultiChannelPoller.fds - added:
property Transport.context - added:
variable DEFAULT_HWM - added:
variable DEFAULT_INCR - added:
variable DEFAULT_PORT - added:
variable ZMQError - added:
variable logger - added:
variable zmq
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
constructor Transport(*args, **kwargs) - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.polling_interval - added:
method Transport.driver_version() - added:
property Channel.client - added:
variable DEFAULT_PORT - added:
variable KZ_CHANNEL_ERRORS - added:
variable KZ_CONNECTION_ERRORS - added:
variable kazoo
- removed:
class EqualityDict(dict) - removed:
class cached_property(object) - removed:
constructor cached_property(fget=…, fset=…, fdel=…, doc=…) - removed:
function emergency_dump_state(state, open_file=…, dump=…) - removed:
function eqhash(o) - removed:
function fxrange(start=…, stop=…, step=…, repeatlast=…) - removed:
function fxrangemax(start=…, stop=…, step=…, max=…) - removed:
function kwdict(kwargs) - removed:
function maybe_list(v) - removed:
function partition(S, sep) - removed:
function reprcall(name, args=…, kwargs=…, sep=…) - removed:
function reprkwargs(kwargs, sep=…, fmt=…) - removed:
function retry_over_time(fun, catch, args=…, kwargs=…, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - removed:
function rpartition(S, sep) - removed:
function say(m, *s) - removed:
function uuid() - removed:
function uuid4() - removed:
method cached_property.deleter(fdel) - removed:
method cached_property.setter(fset) - removed:
variable ctypes - removed:
variable gen_unique_id
- added:
function get_manager(client, hostname=…, port=…, userid=…, password=…)
- removed:
class CompatOrderedDict(dict, MutableMapping) - removed:
class defaultdict(dict) - removed:
constructor CompatOrderedDict(*args, **kwds) - removed:
constructor defaultdict(default_factory=…, *args, **kwargs) - removed:
function all(iterable) - removed:
function any(iterable) - removed:
method CompatOrderedDict.clear() - removed:
method CompatOrderedDict.copy() - removed:
method CompatOrderedDict.items() - removed:
method CompatOrderedDict.iteritems() - removed:
method CompatOrderedDict.iterkeys() - removed:
method CompatOrderedDict.itervalues() - removed:
method CompatOrderedDict.keys() - removed:
method CompatOrderedDict.pop(key, default=…) - removed:
method CompatOrderedDict.popitem(last=…) - removed:
method CompatOrderedDict.setdefault(key, default=…) - removed:
method CompatOrderedDict.update(other=…, **kwds) - removed:
method CompatOrderedDict.values() - removed:
method defaultdict.copy() - removed:
static method CompatOrderedDict.fromkeys(iterable, value=…) - removed:
variable OrderedDict - removed:
variable all - removed:
variable any - added:
class WatchedFileHandler(logging.FileHandler) - added:
class WhateverIO(StringIO) - added:
constructor WatchedFileHandler(*args, **kwargs) - added:
function get_errno(exc) - added:
function next(it, *args) - added:
method WatchedFileHandler.emit(record) - added:
method WhateverIO.write(data) - added:
variable BytesIO - added:
variable WatchedFileHandler - added:
variable WhateverIO - added:
variable is_py3k - added:
variable next
- added:
function default_encode(obj) - added:
function from_utf8(s, *args, **kwargs) - added:
variable is_py3k
- removed:
class Poller(object) - removed:
function get_errno(exc) - removed:
method Poller.poll(timeout) - removed:
variable POLL_ERR - removed:
variable POLL_READ - removed:
variable is_eventlet - removed:
variable poll - added:
function poll(*args, **kwargs)
- removed:
variable WRAPPER_ASSIGNMENTS - removed:
variable WRAPPER_UPDATES - removed:
variable partial - removed:
variable update_wrapper - removed:
variable wraps - added:
class promise(object) - added:
constructor promise(fun, *args, **kwargs) - added:
function maybe_promise(value) - added:
method promise.evaluate()
- removed:
class NullHandler(logging.Handler) - removed:
function get_logger(logger) - removed:
method NullHandler.emit(record)
- added:
function fmatch_best(needle, haystack, min_ratio=…) - added:
function fmatch_iter(needle, haystack, min_ratio=…)
- added:
function parse_url(url)
- changed:
function send_as_task(connection, fun, args, kwargs, priority=…) → function send_as_task(connection, fun, args=…, kwargs=…, priority=…)
- added:
variable logger