Upgrading kombu 0.1 to 0.2
Unknown0.1.0 → 0.2.0
Fetching 1 release from GitHub…0 / 1
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.
- removed:
export Binding - added:
export Queue
- removed:
export rpartition - removed:
function get_backend_cls(backend=…) - removed:
function resolve_backend(backend=…) - removed:
variable BACKEND_ALIASES - removed:
variable DEFAULT_BACKEND
- removed:
class BaseBackend(object) - removed:
class BaseMessage(object) - removed:
constructor BaseBackend(connection, **kwargs) - removed:
constructor BaseMessage(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, **kwargs) - removed:
field BaseBackend.channel_errors - removed:
field BaseBackend.connection_errors - removed:
field BaseBackend.default_port - removed:
field BaseMessage.MessageStateError - removed:
method BaseBackend.close_connection() - removed:
method BaseBackend.establish_connection() - removed:
method BaseBackend.get_channel() - removed:
method BaseMessage.ack() - removed:
method BaseMessage.decode() - removed:
method BaseMessage.reject() - removed:
method BaseMessage.requeue() - removed:
property BaseMessage.acknowledged - removed:
property BaseMessage.payload - removed:
variable ACKNOWLEDGED_STATES
- removed:
class MemoryBackend(virtual.VirtualBaseBackend) - removed:
class MemoryChannel(virtual.Channel) - removed:
field MemoryBackend.Channel - removed:
field MemoryChannel.do_restore - removed:
field MemoryChannel.queues
- removed:
class Backend(BaseBackend) - removed:
class Channel(Channel) - removed:
class Connection(amqp.Connection) - removed:
class Message(BaseMessage) - removed:
constructor Backend(connection, **kwargs) - removed:
constructor Message(channel, amqp_message, **kwargs) - removed:
field Backend.channel_errors - removed:
field Backend.connection_errors - removed:
field Backend.default_port - removed:
field Channel.Message - removed:
method Backend.close_connection(connection) - removed:
method Backend.create_channel(connection) - removed:
method Backend.drain_events(connection, **kwargs) - removed:
method Backend.establish_connection() - 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:
variable DEFAULT_PORT
- removed:
class AsyncoreBackend(SyncBackend) - removed:
class AsyncoreConnection(asyncore_adapter.AsyncoreConnection) - removed:
class BlockingConnection(blocking_adapter.BlockingConnection) - removed:
class Channel(channel.Channel) - removed:
class Message(BaseMessage) - removed:
class SyncBackend(BaseBackend) - removed:
constructor Message(channel, amqp_message, **kwargs) - removed:
constructor SyncBackend(connection, **kwargs) - removed:
field AsyncoreBackend.Connection - removed:
field Channel.Message - removed:
field SyncBackend.Connection - removed:
field SyncBackend.Message - removed:
field SyncBackend.channel_errors - removed:
field SyncBackend.connection_errors - removed:
field SyncBackend.default_port - removed:
method AsyncoreConnection.channel() - removed:
method BlockingConnection.channel() - 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.message_to_python(raw_message) - removed:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - removed:
method SyncBackend.close_connection(connection) - removed:
method SyncBackend.create_channel(connection) - removed:
method SyncBackend.drain_events(connection, **kwargs) - removed:
method SyncBackend.establish_connection() - removed:
variable DEFAULT_PORT
- removed:
class RedisBackend(virtual.VirtualBaseBackend) - removed:
class RedisChannel(virtual.Channel) - removed:
field RedisBackend.Channel - removed:
field RedisBackend.channel_errors - removed:
field RedisBackend.connection_errors - removed:
field RedisBackend.default_port - removed:
field RedisChannel.queues - removed:
method RedisChannel.close() - removed:
property RedisChannel.client - removed:
variable DEFAULT_DB - removed:
variable DEFAULT_PORT
- removed:
class Channel(object) - removed:
class Consume(object) - removed:
class Message(BaseMessage) - removed:
class QualityOfService(object) - removed:
class VirtualBaseBackend(BaseBackend) - removed:
constructor Channel(connection, **kwargs) - removed:
constructor Consume(fun, resources, predicate=…) - removed:
constructor Message(channel, payload, **kwargs) - removed:
constructor QualityOfService(channel, prefetch_count=…, interval=…, do_restore=…) - removed:
constructor VirtualBaseBackend(connection, **kwargs) - removed:
field Channel.Message - removed:
field Channel.do_restore - removed:
field Channel.interval - removed:
field VirtualBaseBackend.Channel - removed:
field VirtualBaseBackend.Consume - removed:
field VirtualBaseBackend.default_port - removed:
field VirtualBaseBackend.interval - removed:
method Channel.basic_ack(delivery_tag) - removed:
method Channel.basic_cancel(consumer_tag) - removed:
method Channel.basic_consume(queue, no_ack, callback, consumer_tag, **kwargs) - removed:
method Channel.basic_get(queue, **kwargs) - removed:
method Channel.basic_publish(message, exchange, routing_key, **kwargs) - removed:
method Channel.basic_qos(prefetch_size, prefetch_count, apply_global=…) - removed:
method Channel.basic_recover(requeue=…) - removed:
method Channel.basic_reject(delivery_tag, requeue=…) - removed:
method Channel.close() - removed:
method Channel.drain_events(timeout=…) - removed:
method Channel.exchange_declare(exchange, type=…, durable=…, auto_delete=…, arguments=…) - removed:
method Channel.exchange_delete(exchange, if_unused=…) - removed:
method Channel.flow(active=…) - 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_bind(queue, exchange, routing_key, arguments=…) - removed:
method Channel.queue_declare(queue, **kwargs) - removed:
method Channel.queue_delete(queue, if_unusued=…, if_empty=…) - removed:
method Channel.queue_purge(queue, **kwargs) - removed:
method Consume.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:
method VirtualBaseBackend.close_channel(channel) - removed:
method VirtualBaseBackend.close_connection(connection) - removed:
method VirtualBaseBackend.create_channel(connection) - removed:
method VirtualBaseBackend.drain_events(timeout=…) - removed:
method VirtualBaseBackend.establish_connection() - removed:
property Channel.qos_manager
- removed:
function entry_to_binding(queue, **options) - added:
function entry_to_queue(queue, **options)
- added:
function compress(body, content_type) - added:
function decompress(body, content_type) - added:
function get_decoder(t) - added:
function get_encoder(t) - added:
function register(encoder, decoder, content_type, aliases=…)
- removed:
method BrokerConnection.create_backend() - removed:
method BrokerConnection.get_backend_cls() - removed:
property BrokerConnection.backend - changed:
constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, **kwargs) → constructor BrokerConnection(hostname=…, userid=…, password=…, virtual_host=…, port=…, insist=…, ssl=…, transport=…, connect_timeout=…, pool=…, backend_cls=…) - added:
class BrokerConnectionPool(object) - added:
constructor BrokerConnectionPool(initial, max=…, ensure=…, preconnect=…) - added:
field BrokerConnection.connect_timeout - added:
field BrokerConnection.create_backend - added:
method BrokerConnection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…) - added:
method BrokerConnection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…) - added:
method BrokerConnection.acquire() - added:
method BrokerConnection.clone(**kwargs) - added:
method BrokerConnection.create_transport() - added:
method BrokerConnection.ensure(fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - added:
method BrokerConnection.ensure_connection(errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - added:
method BrokerConnection.get_transport_cls() - added:
method BrokerConnection.info() - added:
method BrokerConnection.release() - added:
method BrokerConnectionPool.acquire(block=…, timeout=…) - added:
method BrokerConnectionPool.close() - added:
method BrokerConnectionPool.ensure(fun, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…) - added:
method BrokerConnectionPool.grow(n, connect=…) - added:
method BrokerConnectionPool.release(connection) - added:
method BrokerConnectionPool.replace(connection) - added:
property BrokerConnection.transport - added:
property BrokerConnectionPool.active - added:
property BrokerConnectionPool.total
- removed:
class Binding(MaybeChannelBound) - removed:
constructor Binding(name=…, exchange=…, routing_key=…, channel=…, **kwargs) - removed:
field Binding.attrs - removed:
field Binding.auto_delete - removed:
field Binding.durable - removed:
field Binding.exchange - removed:
field Binding.exclusive - removed:
field Binding.name - removed:
field Binding.routing_key - removed:
method Binding.cancel(consumer_tag) - removed:
method Binding.consume(consumer_tag, callback, no_ack=…, nowait=…) - removed:
method Binding.declare(nowait=…) - removed:
method Binding.delete(if_unused=…, if_empty=…, nowait=…) - removed:
method Binding.get(no_ack=…) - removed:
method Binding.purge(nowait=…) - removed:
method Binding.queue_bind(nowait=…) - removed:
method Binding.queue_declare(nowait=…, passive=…) - removed:
method Binding.unbind() - removed:
method Binding.when_bound() - removed:
method Exchange.create_message(message_data, delivery_mode=…, priority=…, content_type=…, content_encoding=…, properties=…, headers=…) - changed:
method Exchange.publish(message, routing_key=…, mandatory=…, immediate=…, headers=…) → method Exchange.publish(message, routing_key=…, mandatory=…, immediate=…) - added:
class Queue(MaybeChannelBound) - added:
constructor Queue(name=…, exchange=…, routing_key=…, channel=…, **kwargs) - added:
field Queue.attrs - added:
field Queue.auto_delete - added:
field Queue.durable - added:
field Queue.exchange - added:
field Queue.exclusive - added:
field Queue.name - added:
field Queue.routing_key - added:
method Exchange.Message(body, delivery_mode=…, priority=…, content_type=…, content_encoding=…, properties=…, headers=…) - added:
method Queue.cancel(consumer_tag) - added:
method Queue.consume(consumer_tag=…, callback=…, no_ack=…, nowait=…) - added:
method Queue.declare(nowait=…) - added:
method Queue.delete(if_unused=…, if_empty=…, nowait=…) - added:
method Queue.get(no_ack=…) - added:
method Queue.purge(nowait=…) - added:
method Queue.queue_bind(nowait=…) - added:
method Queue.queue_declare(nowait=…, passive=…) - added:
method Queue.unbind() - added:
method Queue.when_bound() - added:
variable Binding
- added:
class EnsureExhausted(Exception) - added:
class PoolExhausted(Exception) - added:
class PoolLimitExceeded(Exception) - added:
class TimeoutError(Exception)
- removed:
method Producer.prepare(message_data, serializer=…, content_type=…, content_encoding=…) - changed:
constructor Consumer(channel, bindings, no_ack=…, auto_declare=…, callbacks=…) → constructor Consumer(channel, queues, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…) - changed:
constructor Producer(channel, exchange=…, routing_key=…, serializer=…, auto_declare=…) → constructor Producer(channel, exchange=…, routing_key=…, serializer=…, auto_declare=…, compression=…, on_return=…) - changed:
method Consumer.consume() → method Consumer.consume(delivery_tag=…, no_ack=…) - changed:
method Consumer.receive(message_data, message) → method Consumer.receive(body, message) - changed:
method Producer.publish(message_data, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…) → method Producer.publish(body, routing_key=…, delivery_mode=…, mandatory=…, immediate=…, priority=…, content_type=…, content_encoding=…, serializer=…, headers=…, compression=…) - added:
field Producer.compression - added:
field Producer.on_return
- added:
class SimpleBase(object) - added:
class SimpleBuffer(SimpleQueue) - added:
class SimpleQueue(SimpleBase) - added:
constructor SimpleBase(channel, producer, consumer, no_ack=…, channel_autoclose=…) - added:
constructor SimpleQueue(channel, name, no_ack=…, queue_opts=…, exchange_opts=…, serializer=…, compression=…, **kwargs) - added:
field SimpleBuffer.exchange_opts - added:
field SimpleBuffer.no_ack - added:
field SimpleBuffer.queue_opts - added:
field SimpleQueue.exchange_opts - added:
field SimpleQueue.no_ack - added:
field SimpleQueue.queue_opts - added:
method SimpleBase.clear() - added:
method SimpleBase.close() - added:
method SimpleBase.get(block=…, timeout=…, sync=…) - added:
method SimpleBase.get_nowait() - added:
method SimpleBase.put(message, serializer=…, headers=…, compression=…, routing_key=…, **kwargs) - added:
method SimpleBase.qsize()
- added:
export rpartition - added:
function get_transport_cls(transport=…) - added:
function resolve_transport(transport=…) - added:
variable DEFAULT_TRANSPORT - added:
variable TRANSPORT_ALIASES
- added:
class Message(object) - added:
class Transport(object) - added:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, **kwargs) - added:
constructor Transport(client, **kwargs) - added:
field Message.MessageStateError - added:
field Transport.channel_errors - added:
field Transport.client - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
method Message.ack() - added:
method Message.decode() - added:
method Message.reject() - added:
method Message.requeue() - 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 Message.acknowledged - added:
property Message.payload - added:
variable ACKNOWLEDGED_STATES
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
field Channel.do_restore - added:
field Channel.queues - added:
field Transport.Channel
- added:
class Channel(_Channel) - added:
class Connection(amqp.Connection) - added:
class Message(base.Message) - added:
class Transport(base.Transport) - added:
constructor Connection(*args, **kwargs) - added:
constructor Message(channel, msg, **kwargs) - added:
constructor Transport(client, **kwargs) - added:
field Channel.Message - added:
field Channel.events - 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(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Connection.channel(channel_id=…) - added:
method Connection.drain_events(allowed_methods=…, timeout=…) - added:
method Connection.read_timeout(timeout=…) - added:
method Connection.wait_multi(channels, allowed_methods=…, timeout=…) - 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:
variable DEFAULT_PORT
- added:
class AsyncoreConnection(asyncore_adapter.AsyncoreConnection) - added:
class AsyncoreTransport(SyncTransport) - added:
class BlockingConnection(blocking_adapter.BlockingConnection) - added:
class Channel(channel.Channel) - added:
class Message(base.Message) - added:
class SyncTransport(base.Transport) - added:
constructor Message(channel, amqp_message, **kwargs) - added:
constructor SyncTransport(client, **kwargs) - added:
field AsyncoreTransport.Connection - added:
field Channel.Message - added:
field SyncTransport.Connection - added:
field SyncTransport.Message - added:
field SyncTransport.channel_errors - added:
field SyncTransport.connection_errors - added:
field SyncTransport.default_port - added:
method AsyncoreConnection.channel() - added:
method BlockingConnection.channel() - added:
method Channel.basic_ack(delivery_tag) - added:
method Channel.basic_consume(queue, no_ack=…, consumer_tag=…, callback=…, nowait=…) - added:
method Channel.basic_get(queue, no_ack) - added:
method Channel.basic_publish(message, exchange, routing_key, mandatory=…, immediate=…) - added:
method Channel.message_to_python(raw_message) - added:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method SyncTransport.close_connection(connection) - added:
method SyncTransport.create_channel(connection) - added:
method SyncTransport.drain_events(connection, **kwargs) - added:
method SyncTransport.establish_connection() - added:
variable DEFAULT_PORT
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
field Channel.queues - added:
field Transport.Channel - added:
field Transport.channel_errors - added:
field Transport.connection_errors - added:
field Transport.default_port - added:
method Channel.close() - added:
property Channel.client - added:
variable DEFAULT_DB - added:
variable DEFAULT_PORT
- added:
class Channel(object) - added:
class FairCycle(object) - added:
class Message(base.Message) - added:
class QualityOfService(object) - added:
class Transport(base.Transport) - added:
constructor Channel(connection, **kwargs) - added:
constructor FairCycle(fun, resources, predicate=…) - added:
constructor Message(channel, payload, **kwargs) - added:
constructor QualityOfService(channel, prefetch_count=…, interval=…, do_restore=…) - added:
constructor Transport(client, **kwargs) - added:
field Channel.Message - added:
field Channel.do_restore - added:
field Channel.interval - added:
field Transport.Channel - added:
field Transport.Cycle - added:
field Transport.default_port - added:
field Transport.interval - added:
method Channel.basic_ack(delivery_tag) - added:
method Channel.basic_cancel(consumer_tag) - added:
method Channel.basic_consume(queue, no_ack, callback, consumer_tag, **kwargs) - added:
method Channel.basic_get(queue, **kwargs) - added:
method Channel.basic_publish(message, exchange, routing_key, **kwargs) - added:
method Channel.basic_qos(prefetch_size, prefetch_count, apply_global=…) - added:
method Channel.basic_recover(requeue=…) - added:
method Channel.basic_reject(delivery_tag, requeue=…) - added:
method Channel.close() - added:
method Channel.drain_events(timeout=…) - added:
method Channel.exchange_declare(exchange, type=…, durable=…, auto_delete=…, arguments=…) - added:
method Channel.exchange_delete(exchange, if_unused=…) - added:
method Channel.flow(active=…) - added:
method Channel.message_to_python(raw_message) - added:
method Channel.prepare_message(message_data, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Channel.queue_bind(queue, exchange, routing_key, arguments=…) - added:
method Channel.queue_declare(queue, **kwargs) - added:
method Channel.queue_delete(queue, if_unusued=…, if_empty=…) - added:
method Channel.queue_purge(queue, **kwargs) - added:
method FairCycle.get() - added:
method Message.reject() - added:
method QualityOfService.ack(delivery_tag) - added:
method QualityOfService.append(message, delivery_tag) - added:
method QualityOfService.can_consume() - added:
method QualityOfService.requeue(delivery_tag) - added:
method QualityOfService.restore_unacked() - added:
method QualityOfService.restore_unacked_once() - added:
method Transport.close_channel(channel) - added:
method Transport.close_connection(connection) - added:
method Transport.create_channel(connection) - added:
method Transport.drain_events(connection, timeout=…) - added:
method Transport.establish_connection() - added:
property Channel.qos_manager
- added:
function repeatlast(it) - added:
function retry_over_time(fun, catch, args=…, kwargs=…, errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…)
- added:
variable WRAPPER_ASSIGNMENTS - added:
variable WRAPPER_UPDATES - added:
variable partial - added:
variable update_wrapper - added:
variable wraps