Upgrading kombu 0.2 to 0.9
Unknown0.2.0 → 0.9.7
Fetching 7 releases from GitHub…0 / 7
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:
method MaybeChannelBound.revive(channel)
- removed:
function ConsumerSet(connection, from_dict=…, consumers=…, callbacks=…, **kwargs) - removed:
function iterconsume(connection, consumer, no_ack=…, limit=…) - added:
class ConsumerSet(messaging.Consumer) - added:
constructor ConsumerSet(connection, from_dict=…, consumers=…, callbacks=…, **kwargs) - added:
method ConsumerSet.add_consumer(consumer) - added:
method ConsumerSet.add_consumer_from_dict(queue, **options) - added:
method ConsumerSet.close() - added:
method ConsumerSet.discard_all() - added:
method ConsumerSet.iterconsume(limit=…, no_ack=…)
- added:
function encoders()
- removed:
class BrokerConnectionPool(object) - removed:
constructor BrokerConnectionPool(initial, max=…, ensure=…, preconnect=…) - removed:
method BrokerConnection.acquire() - removed:
method BrokerConnection.close() - removed:
method BrokerConnectionPool.acquire(block=…, timeout=…) - removed:
method BrokerConnectionPool.close() - removed:
method BrokerConnectionPool.ensure(fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - removed:
method BrokerConnectionPool.grow(n, connect=…) - removed:
method BrokerConnectionPool.release(connection) - removed:
method BrokerConnectionPool.replace(connection) - removed:
property BrokerConnectionPool.active - removed:
property BrokerConnectionPool.total - changed:
constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, pool=…, backend_cls=…) → constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, backend_cls=…) - changed:
method BrokerConnection.ensure(fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) → method BrokerConnection.ensure(obj, fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - added:
class ChannelPool(Resource) - added:
class ConnectionPool(Resource) - added:
class Resource(object) - added:
constructor ChannelPool(connection, limit=…, preload=…) - added:
constructor ConnectionPool(connection, limit=…, preload=…) - added:
constructor Resource(limit=…, preload=…) - added:
field BrokerConnection.close - added:
field ChannelPool.LimitExceeded - added:
field ConnectionPool.LimitExceeded - added:
method BrokerConnection.ChannelPool(limit=…, preload=…) - added:
method BrokerConnection.Pool(limit=…, preload=…) - added:
method ChannelPool.new() - added:
method ChannelPool.prepare(channel) - added:
method ChannelPool.setup() - added:
method ConnectionPool.new() - added:
method ConnectionPool.prepare(resource) - added:
method ConnectionPool.setup() - added:
method Resource.acquire(block=…, timeout=…) - added:
method Resource.prepare(resource) - added:
method Resource.release(resource) - added:
method Resource.setup()
- removed:
variable Binding - changed:
method Exchange.publish(message, routing_key=…, mandatory=…, immediate=…) → method Exchange.publish(message, routing_key=…, mandatory=…, immediate=…, exchange=…)
- removed:
class PoolExhausted(Exception) - removed:
class PoolLimitExceeded(Exception) - added:
class ChannelLimitExceeded(LimitExceeded) - added:
class ConnectionLimitExceeded(LimitExceeded) - added:
class LimitExceeded(Exception)
- changed:
method Consumer.consume(delivery_tag=…, no_ack=…) → method Consumer.consume(no_ack=…) - changed:
method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…) → method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…) - added:
field Consumer.channel - added:
field Consumer.queues - added:
field Producer.channel - added:
method Consumer.cancel_by_queue(queue) - added:
method Consumer.revive(channel) - added:
method Producer.revive(channel)
- added:
class Mailbox(object) - added:
class Node(object) - added:
constructor Mailbox(namespace, type=…, connection=…) - added:
constructor Node(hostname, state=…, channel=…, handlers=…, mailbox=…) - added:
field Mailbox.connection - added:
field Mailbox.exchange - added:
field Mailbox.exchange_fmt - added:
field Mailbox.namespace - added:
field Mailbox.node_cls - added:
field Mailbox.reply_exchange - added:
field Mailbox.reply_exchange_fmt - added:
field Mailbox.type - added:
field Node.channel - added:
field Node.handlers - added:
field Node.hostname - added:
field Node.mailbox - added:
field Node.state - added:
method Mailbox.Node(hostname=…, state=…, channel=…, handlers=…) - added:
method Mailbox.abcast(command, kwargs=…) - added:
method Mailbox.call(destination, command, kwargs=…, timeout=…, callback=…, channel=…) - added:
method Mailbox.cast(destination, command, kwargs=…) - added:
method Mailbox.get_queue(hostname) - added:
method Mailbox.get_reply_queue(ticket) - added:
method Mailbox.multi_call(command, kwargs=…, timeout=…, limit=…, callback=…, channel=…) - added:
method Node.Consumer(channel=…, **options) - added:
method Node.dispatch(method, arguments=…, reply_to=…) - added:
method Node.dispatch_from_message(message) - added:
method Node.handle(method, arguments=…) - added:
method Node.handle_call(method, arguments) - added:
method Node.handle_cast(method, arguments) - added:
method Node.handle_message(message_data, message) - added:
method Node.handler(fun) - added:
method Node.listen(channel=…, callback=…) - added:
method Node.reply(data, exchange, routing_key, **kwargs)
- added:
class SerializerRegistry(object) - added:
constructor SerializerRegistry() - added:
function raw_encode(data) - added:
function register_json() - added:
function register_msgpack() - added:
function register_pickle() - added:
function register_yaml() - added:
method SerializerRegistry.decode(data, content_type, content_encoding) - added:
method SerializerRegistry.encode(data, serializer=…) - added:
method SerializerRegistry.register(name, encoder, decoder, content_type, content_encoding=…) - added:
variable decode - added:
variable encode - added:
variable register
- added:
variable MISSING_LIB
- changed:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, **kwargs) → constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, **kwargs) - added:
field Message.body - added:
field Message.channel - added:
field Message.content_encoding - added:
field Message.content_type - added:
field Message.delivery_info - added:
field Message.delivery_tag - added:
field Message.headers - added:
field Message.properties - added:
method Transport.close_channel(connection)
- 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.interval - added:
method Channel.close() - added:
property Channel.client - added:
variable DEFAULT_PORT
- added:
field Transport.state
- 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.interval - added:
method Channel.close() - added:
property Channel.client - added:
variable DEFAULT_HOST - added:
variable DEFAULT_PORT
- added:
field Transport.Connection
- 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.interval - added:
function create_message_view(db) - added:
property Channel.client - added:
variable DEFAULT_DATABASE - added:
variable DEFAULT_PORT
- added:
field AsyncoreConnection.Super - added:
method AsyncoreConnection.ensure_drain_events(timeout=…) - added:
method AsyncoreConnection.on_data_available(buf) - added:
method BlockingConnection.ensure_drain_events(timeout=…) - added:
method Channel.queue_purge(queue=…, nowait=…)
- removed:
field Channel.queues - removed:
field Transport.channel_errors - removed:
field Transport.connection_errors - added:
class ChannelPoller(Thread) - added:
constructor Channel(*args, **kwargs) - added:
constructor ChannelPoller(drain_events) - added:
constructor Transport(*args, **kwargs) - added:
field Channel.keyprefix_fanout - added:
field Channel.keyprefix_queue - added:
field Channel.sep - added:
field Channel.supports_fanout - added:
field ChannelPoller.drain_events - added:
field ChannelPoller.inbound - added:
field ChannelPoller.poll_request - added:
field ChannelPoller.shutdown - added:
field Transport.interval - added:
method Channel.drain_events(timeout=…) - added:
method Channel.get_table(exchange) - added:
method ChannelPoller.close() - added:
method ChannelPoller.ensure_started() - added:
method ChannelPoller.poll() - added:
method ChannelPoller.run()
- removed:
class FairCycle(object) - removed:
class QualityOfService(object) - removed:
constructor FairCycle(fun, resources, predicate=…) - removed:
constructor QualityOfService(channel, prefetch_count=…, interval=…, do_restore=…) - removed:
field Channel.interval - removed:
method FairCycle.get() - removed:
method Message.reject() - removed:
method QualityOfService.ack(delivery_tag) - removed:
method QualityOfService.append(message, delivery_tag) - removed:
method QualityOfService.can_consume() - removed:
method QualityOfService.requeue(delivery_tag) - removed:
method QualityOfService.restore_unacked() - removed:
method QualityOfService.restore_unacked_once() - removed:
property Channel.qos_manager - changed:
class Channel(object) → class Channel(AbstractChannel) - changed:
method Channel.basic_qos(prefetch_size, prefetch_count, apply_global=…) → method Channel.basic_qos(prefetch_size=…, prefetch_count=…, apply_global=…) - changed:
method Channel.exchange_declare(exchange, type=…, durable=…, auto_delete=…, arguments=…) → method Channel.exchange_declare(exchange, type=…, durable=…, auto_delete=…, arguments=…, nowait=…) - changed:
method Channel.exchange_delete(exchange, if_unused=…) → method Channel.exchange_delete(exchange, if_unused=…, nowait=…) - changed:
method Channel.queue_bind(queue, exchange, routing_key, arguments=…) → method Channel.queue_bind(queue, exchange, routing_key, arguments=…, **kwargs) - changed:
method Channel.queue_delete(queue, if_unusued=…, if_empty=…) → method Channel.queue_delete(queue, if_unusued=…, if_empty=…, **kwargs) - added:
class AbstractChannel(object) - added:
class BrokerState(object) - added:
class NotEquivalentError(Exception) - added:
class QoS(object) - added:
constructor BrokerState(exchanges=…, bindings=…) - added:
constructor QoS(channel, prefetch_count=…) - added:
export FairCycle - added:
export Finalize - added:
export OrderedDict - added:
export STANDARD_EXCHANGE_TYPES - added:
export base - added:
export emergency_dump_state - added:
export say - added:
field BrokerState.bindings - added:
field BrokerState.exchanges - added:
field Channel.exchange_types - added:
field Channel.supports_fanout - added:
field QoS.prefetch_count - added:
field Transport.channels - added:
field Transport.cycle - added:
field Transport.state - added:
method Channel.get_table(exchange) - added:
method Channel.typeof(exchange) - added:
method Message.serializable() - added:
method QoS.ack(delivery_tag) - added:
method QoS.append(message, delivery_tag) - added:
method QoS.can_consume() - added:
method QoS.reject(delivery_tag, requeue=…) - added:
method QoS.restore_unacked() - added:
method QoS.restore_unacked_once() - added:
property Channel.cycle - added:
property Channel.qos - added:
property Channel.state
- added:
class DirectExchange(ExchangeType) - added:
class ExchangeType(object) - added:
class FanoutExchange(ExchangeType) - added:
class TopicExchange(ExchangeType) - added:
constructor ExchangeType(channel) - added:
field TopicExchange.wildcards - added:
method DirectExchange.lookup(table, exchange, routing_key, default) - added:
method ExchangeType.equivalent(prev, exchange, type, durable, auto_delete, arguments) - added:
method ExchangeType.lookup(table, exchange, routing_key, default) - added:
method ExchangeType.prepare_bind(queue, exchange, routing_key, arguments) - added:
method FanoutExchange.lookup(table, exchange, routing_key, default) - added:
method TopicExchange.key_to_pattern(rkey) - added:
method TopicExchange.lookup(table, exchange, routing_key, default) - added:
method TopicExchange.prepare_bind(queue, exchange, routing_key, arguments) - added:
variable STANDARD_EXCHANGE_TYPES
- added:
class FairCycle(object) - added:
constructor FairCycle(fun, resources, predicate=…) - added:
method FairCycle.get()
- removed:
class OrderedDict(dict, MutableMapping) - removed:
constructor OrderedDict(*args, **kwds) - removed:
method OrderedDict.clear() - removed:
method OrderedDict.copy() - removed:
method OrderedDict.items() - removed:
method OrderedDict.iteritems() - removed:
method OrderedDict.iterkeys() - removed:
method OrderedDict.itervalues() - removed:
method OrderedDict.keys() - removed:
method OrderedDict.pop(key, default=…) - removed:
method OrderedDict.popitem(last=…) - removed:
method OrderedDict.setdefault(key, default=…) - removed:
method OrderedDict.update(other=…, **kwds) - removed:
method OrderedDict.values() - removed:
static method OrderedDict.fromkeys(iterable, value=…) - added:
function emergency_dump_state(state, open_file=…, dump=…) - added:
function gen_unique_id() - added:
function kwdict(kwargs) - added:
function say(m, *s) - added:
function uuid4() - added:
variable ctypes
- added:
class OrderedDict(dict, MutableMapping) - added:
constructor OrderedDict(*args, **kwds) - added:
function all(iterable) - added:
function any(iterable) - added:
method OrderedDict.clear() - added:
method OrderedDict.copy() - added:
method OrderedDict.items() - added:
method OrderedDict.iteritems() - added:
method OrderedDict.iterkeys() - added:
method OrderedDict.itervalues() - added:
method OrderedDict.keys() - added:
method OrderedDict.pop(key, default=…) - added:
method OrderedDict.popitem(last=…) - added:
method OrderedDict.setdefault(key, default=…) - added:
method OrderedDict.update(other=…, **kwds) - added:
method OrderedDict.values() - added:
static method OrderedDict.fromkeys(iterable, value=…) - added:
variable all - added:
variable any
- added:
class Finalize(object) - added:
constructor Finalize(obj, callback, args=…, kwargs=…, exitpriority=…) - added:
method Finalize.cancel() - added:
method Finalize.still_active()