Upgrading kombu 0.9 to 1
Unknown0.9.7 → 1.5.1
Fetching 37 releases from GitHub…0 / 37
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:
class no_install(install) - added:
method no_install.run(*args, **kwargs)
- added:
class TransportCase(unittest.TestCase) - added:
field TransportCase.connected - added:
field TransportCase.connection_options - added:
field TransportCase.event_loop_max - added:
field TransportCase.message_size_limit - added:
field TransportCase.password - added:
field TransportCase.prefix - added:
field TransportCase.reliable_purge - added:
field TransportCase.sep - added:
field TransportCase.skip_test_reason - added:
field TransportCase.suppress_disorder_warning - added:
field TransportCase.transport - added:
field TransportCase.userid - added:
function consumeN(conn, consumer, n=…, timeout=…) - added:
function say(msg) - added:
method TransportCase.P(rest) - added:
method TransportCase.after_connect(connection) - added:
method TransportCase.before_connect() - added:
method TransportCase.do_connect() - added:
method TransportCase.get_connection(**options) - added:
method TransportCase.purge(names) - added:
method TransportCase.purge_consumer(consumer) - added:
method TransportCase.setUp() - added:
method TransportCase.tearDown() - added:
method TransportCase.test_basic_get() - added:
method TransportCase.test_cyclic_reference_channel() - added:
method TransportCase.test_cyclic_reference_connection() - added:
method TransportCase.test_cyclic_reference_transport() - added:
method TransportCase.test_produce__consume() - added:
method TransportCase.test_produce__consume_large_messages(bytes=…, n=…, charset=…) - added:
method TransportCase.test_produce__consume_multiple() - added:
method TransportCase.test_purge() - added:
method TransportCase.test_timeout() - added:
method TransportCase.verify_alive()
- removed:
export BrokerConnection - removed:
export Consumer - removed:
export Exchange - removed:
export Producer - removed:
export Queue - added:
class module(ModuleType) - added:
export debug - added:
variable all_by_module - added:
variable new_module - added:
variable object_origins - added:
variable old_module
- added:
method Object.as_dict(recurse=…)
- added:
class LamportClock(object) - added:
constructor LamportClock(initial_value=…) - added:
field LamportClock.value - added:
method LamportClock.adjust(other) - added:
method LamportClock.forward()
- added:
class Broadcast(entity.Queue) - added:
constructor Broadcast(name=…, queue=…, **kwargs) - added:
function entry_to_queue(queue, **options) - added:
function maybe_declare(entity, channel) - added:
variable declared_entities
- removed:
function entry_to_queue(queue, **options) - changed:
constructor Publisher(connection, exchange=…, routing_key=…, exchange_type=…, durable=…, auto_delete=…, **kwargs) → constructor Publisher(connection, exchange=…, routing_key=…, exchange_type=…, durable=…, auto_delete=…, channel=…, **kwargs) - added:
method Consumer.revive(channel) - added:
method ConsumerSet.revive(channel) - added:
property Publisher.backend
- changed:
constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, backend_cls=…) → constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, transport_options=…, login_method=…, **kwargs) - changed:
method BrokerConnection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…) → method BrokerConnection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - changed:
method BrokerConnection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…) → method BrokerConnection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) - changed:
method BrokerConnection.ensure(obj, fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) → method BrokerConnection.ensure(obj, fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, on_revive=…) - changed:
method Resource.acquire(block=…, timeout=…) → method Resource.acquire(*args, **kwargs) - added:
class PoolChannelContext(object) - added:
constructor PoolChannelContext(pool, block=…) - added:
field BrokerConnection.URI_FORMAT - added:
field BrokerConnection.skip_uri_transports - added:
function parse_url(url) - added:
method BrokerConnection.Consumer(queues=…, channel=…, *args, **kwargs) - added:
method BrokerConnection.Producer(channel=…, *args, **kwargs) - added:
method BrokerConnection.as_uri(include_password=…) - added:
method BrokerConnection.autoretry(fun, channel=…, **ensure_options) - added:
method BrokerConnection.maybe_close_channel(channel) - added:
method BrokerConnection.revive(new_channel) - added:
method ConnectionPool.acquire_channel(block=…) - added:
method ConnectionPool.close_resource(resource) - added:
method ConnectionPool.release_resource(resource) - added:
method Resource.close_resource(resource) - added:
method Resource.force_close_all() - added:
method Resource.release_resource(resource) - added:
method Resource.replace(resource) - added:
property BrokerConnection.connected - added:
property BrokerConnection.default_channel - added:
variable Connection - added:
variable URI_FORMAT
- added:
field Queue.no_ack
- removed:
class EnsureExhausted(Exception) - added:
class StdChannelError(Exception) - added:
class VersionMismatch(Exception)
- changed:
method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…) → method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…, exchange=…, **properties) - added:
field Consumer.close - added:
field Producer.close - added:
method Consumer.add_queue(queue) - added:
method Consumer.consuming_from(queue) - added:
method Producer.release() - added:
variable Exchange - added:
variable Queue
- added:
class ConsumerMixin(object) - added:
field ConsumerMixin.connect_max_retries - added:
field ConsumerMixin.should_stop - added:
method ConsumerMixin.Consumer() - added:
method ConsumerMixin.consume(limit=…, timeout=…, safety_interval=…, **kwargs) - added:
method ConsumerMixin.error(msg, *args) - added:
method ConsumerMixin.extra_context(connection, channel) - added:
method ConsumerMixin.get_consumers(Consumer, channel) - added:
method ConsumerMixin.info(msg, *args) - added:
method ConsumerMixin.on_connection_error(exc, interval) - added:
method ConsumerMixin.on_connection_revived() - added:
method ConsumerMixin.on_consume_ready(connection, channel) - added:
method ConsumerMixin.on_iteration() - added:
method ConsumerMixin.run() - added:
property ConsumerMixin.restart_limit
- changed:
method Node.handle_message(message_data, message) → method Node.handle_message(body, message)
- added:
class PoolGroup(EqualityDict) - added:
class ProducerPool(Resource) - added:
constructor PoolGroup(limit=…) - added:
constructor ProducerPool(connections, *args, **kwargs) - added:
function get_limit() - added:
function register_group(group) - added:
function reset(*args, **kwargs) - added:
function set_limit(limit, force=…, reset_after=…) - added:
method PoolGroup.create(resource, limit) - added:
method ProducerPool.Producer(connection) - added:
method ProducerPool.create_producer() - added:
method ProducerPool.new() - added:
method ProducerPool.prepare(p) - added:
method ProducerPool.release(resource) - added:
method ProducerPool.setup() - added:
variable connections - added:
variable producers
- changed:
method SerializerRegistry.decode(data, content_type, content_encoding) → method SerializerRegistry.decode(data, content_type, content_encoding, force=…) - added:
method SerializerRegistry.disable(name) - added:
method SerializerRegistry.unregister(name) - added:
variable bytes_type - added:
variable cpickle - added:
variable pickle - added:
variable unregister
- changed:
method SimpleBase.get(block=…, timeout=…, sync=…) → method SimpleBase.get(block=…, timeout=…)
- added:
function blocking(fun, *args, **kwargs) - added:
function detect_environment() - added:
function select_blocking_method(type)
- added:
class Channel(virtual.Channel) - added:
class Table(Domain) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
field Channel.Table - added:
field Channel.default_region - added:
field Channel.domain_format - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
field Transport.polling_interval - added:
method Channel.basic_ack(delivery_tag) - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, no_ack, *args, **kwargs) - added:
method Channel.close() - added:
method Channel.entity_name(name, table=…) - added:
method Channel.exchange_delete(exchange, **kwargs) - added:
method Channel.get_exchanges() - added:
method Channel.get_table(exchange) - added:
method Table.create_binding(queue) - added:
method Table.exchange_delete(exchange) - added:
method Table.get_exchanges() - added:
method Table.get_item(item_name) - added:
method Table.get_queue(queue) - added:
method Table.queue_bind(exchange, routing_key, pattern, queue) - added:
method Table.queue_delete(queue) - added:
method Table.routes_for(exchange) - added:
method Table.select(query=…, next_token=…, consistent_read=…, max_items=…) - added:
property Channel.conninfo - added:
property Channel.region - added:
property Channel.sdb - added:
property Channel.sqs - added:
property Channel.supports_fanout - added:
property Channel.table - added:
property Channel.transport_options - added:
property Channel.visibility_timeout - added:
variable CHARS_REPLACE_TABLE
- added:
class StdChannel(object) - added:
field StdChannel.no_ack_consumers - added:
method StdChannel.Consumer(*args, **kwargs) - added:
method StdChannel.Producer(*args, **kwargs) - added:
method StdChannel.after_reply_message_received(queue) - added:
method StdChannel.list_bindings() - added:
method Transport.verify_connection(connection) - added:
property Transport.default_connection_params
- 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, message, **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:
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.establish_connection() - added:
property Transport.default_connection_params - added:
variable DEFAULT_PORT
- added:
method Channel.after_reply_message_received(queue)
- changed:
class Channel(_Channel) → class Channel(_Channel, base.StdChannel) - added:
class SSLError(Exception) - added:
constructor Channel(*args, **kwargs) - added:
method Channel.basic_cancel(consumer_tag, **kwargs) - added:
method Channel.basic_consume(*args, **kwargs) - added:
method Channel.close() - added:
method Transport.verify_connection(connection) - added:
property Transport.default_connection_params
- changed:
class Channel(channel.Channel) → class Channel(channel.Channel, base.StdChannel) - added:
constructor AsyncoreConnection(client, *args, **kwargs) - added:
constructor BlockingConnection(client, *args, **kwargs) - added:
field BlockingConnection.Super - added:
method AsyncoreConnection.close() - added:
method BlockingConnection.close() - added:
method Channel.close() - added:
property Channel.channel_id - added:
property SyncTransport.default_connection_params - added:
variable BASIC_PROPERTIES
- removed:
class ChannelPoller(Thread) - removed:
constructor ChannelPoller(drain_events) - removed:
field Channel.keyprefix_fanout - removed:
field ChannelPoller.drain_events - removed:
field ChannelPoller.inbound - removed:
field ChannelPoller.poll_request - removed:
field ChannelPoller.shutdown - removed:
method Channel.drain_events(timeout=…) - removed:
method ChannelPoller.close() - removed:
method ChannelPoller.ensure_started() - removed:
method ChannelPoller.poll() - removed:
method ChannelPoller.run() - added:
class MultiChannelPoller(object) - added:
constructor MultiChannelPoller() - added:
field MultiChannelPoller.eventflags - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, *args, **kwargs) - added:
method MultiChannelPoller.add(channel) - added:
method MultiChannelPoller.close() - added:
method MultiChannelPoller.discard(channel) - added:
method MultiChannelPoller.get(timeout=…) - added:
property Channel.active_queues - added:
property Channel.subclient
- changed:
class Channel(AbstractChannel) → class Channel(AbstractChannel, base.StdChannel) - changed:
method Channel.queue_declare(queue, **kwargs) → method Channel.queue_declare(queue, passive=…, auto_delete=…, **kwargs) - added:
class Base64(object) - added:
class UndeliverableWarning(UserWarning) - added:
export StdChannelError - added:
export bytes_to_str - added:
export str_to_bytes - added:
field Channel.body_encoding - added:
field Channel.codecs - added:
field Channel.deadletter_queue - added:
field Channel.from_transport_options - added:
field Transport.polling_interval - added:
method Base64.decode(s) - added:
method Base64.encode(s) - added:
method Channel.after_reply_message_received(queue) - added:
method Channel.decode_body(body, encoding=…) - added:
method Channel.encode_body(body, encoding=…) - added:
method Channel.get_exchanges() - added:
method Channel.list_bindings() - added:
method QoS.get(delivery_tag) - added:
property Transport.default_connection_params - added:
variable UNDELIVERABLE_FMT
- added:
field DirectExchange.type - added:
field ExchangeType.type - added:
field FanoutExchange.type - added:
field TopicExchange.type - added:
method DirectExchange.deliver(message, exchange, routing_key, **kwargs) - added:
method FanoutExchange.deliver(message, exchange, routing_key, **kwargs) - added:
method TopicExchange.deliver(message, exchange, routing_key, **kwargs)
- changed:
method FairCycle.get() → method FairCycle.get(**kwargs) - added:
method FairCycle.close()
- removed:
function gen_unique_id() - removed:
function repeatlast(it) - added:
class EqualityDict(dict) - added:
class cached_property(object) - added:
constructor cached_property(fget=…, fset=…, fdel=…, doc=…) - added:
function eqhash(o) - added:
function fxrange(start=…, stop=…, step=…, repeatlast=…) - added:
function fxrangemax(start=…, stop=…, step=…, max=…) - added:
function reprcall(name, args=…, kwargs=…, sep=…) - added:
function reprkwargs(kwargs, sep=…, fmt=…) - added:
function uuid() - added:
method cached_property.deleter(fdel) - added:
method cached_property.setter(fset) - added:
variable gen_unique_id
- 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:
class CompatOrderedDict(dict, MutableMapping) - added:
class LifoQueue(Queue) - added:
class defaultdict(dict) - added:
constructor CompatOrderedDict(*args, **kwds) - added:
constructor defaultdict(default_factory=…, *args, **kwargs) - added:
method CompatOrderedDict.clear() - added:
method CompatOrderedDict.copy() - added:
method CompatOrderedDict.items() - added:
method CompatOrderedDict.iteritems() - added:
method CompatOrderedDict.iterkeys() - added:
method CompatOrderedDict.itervalues() - added:
method CompatOrderedDict.keys() - added:
method CompatOrderedDict.pop(key, default=…) - added:
method CompatOrderedDict.popitem(last=…) - added:
method CompatOrderedDict.setdefault(key, default=…) - added:
method CompatOrderedDict.update(other=…, **kwds) - added:
method CompatOrderedDict.values() - added:
method defaultdict.copy() - added:
static method CompatOrderedDict.fromkeys(iterable, value=…) - added:
variable OrderedDict
- added:
class Logwrapped(object) - added:
constructor Logwrapped(instance, logger=…, ident=…) - added:
function setup_logging(loglevel=…, loggers=…)
- added:
function bytes_to_str(s) - added:
function default_encoding() - added:
function ensure_bytes(s) - added:
function safe_repr(o, errors=…) - added:
function safe_str(s, errors=…) - added:
function str_to_bytes(s) - added:
variable bytes_t - added:
variable ensure_bytes - added:
variable str_t
- added:
class Poller(object) - added:
function get_errno(exc) - added:
method Poller.poll(timeout) - added:
variable POLL_ERR - added:
variable POLL_READ - added:
variable is_eventlet - added:
variable poll
- added:
class TokenBucket(object) - added:
constructor TokenBucket(fill_rate, capacity=…) - added:
field TokenBucket.capacity - added:
field TokenBucket.fill_rate - added:
field TokenBucket.timestamp - added:
method TokenBucket.can_consume(tokens=…) - added:
method TokenBucket.expected_time(tokens=…)
- added:
class NullHandler(logging.Handler) - added:
function get_logger(logger) - added:
method NullHandler.emit(record)
- added:
function send_as_task(connection, fun, args, kwargs, priority=…) - added:
variable connection - added:
variable priority_to_routing_key
- added:
variable task_exchange - added:
variable task_queues
- added:
function hello_task(who=…)
- added:
class Worker(ConsumerMixin) - added:
constructor Worker(connection) - added:
method Worker.get_consumers(Consumer, channel) - added:
method Worker.process_task(body, message)