Upgrading kombu 3 to 4
Breaking3.0.37 → 4.6.11Breaking9Security1Platform5New48Changed44Fixed75Other18
BreakingUpgrade verdict
9 breaking changes and 5 platform requirement changes and a security fix.
In plain terms
- Several transports are no longer supported and must be replaced.
- Redis fanout messages are now isolated per virtual host and can be filtered by pattern. This is on by default, so older clients may not see each other's messages.
- A deprecated way to add a queue from a dictionary has been removed; use the regular add_queue method instead.
- An old serialization helper has been removed; use dumps instead.
Must act Top 5 of 15 that need code or config changes
Requires Python >=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, !=3.4.* from 4.6.0 (none stated before).
Drops anyjson.
What you must change
Breaking9
Removes the Django ORM, SQLAlchemy ORM, Beanstalk, ZeroMQ, and amqplib transports.
Redis fanout exchanges are no longer visible between vhosts and fanout messages can be filtered by patterns.
fanout_prefixfanout_patternsConnectionRemoves the deprecated method Consumer.add_queue_from_dict.
Consumer.add_queue_from_dictConsumer.add_queueQueue.from_dictRemoves the deprecated function kombu.serialization.encode.
kombu.serialization.encodekombu.serialization.dumpsRemoves the deprecated function kombu.serialization.decode.
kombu.serialization.decodekombu.serialization.loadsRemoves the kombu.syn module; detect_environment moves to kombu.utils.compat.
kombu.syndetect_environmentkombu.utils.compatkombu.Message now takes body as the first argument instead of channel.
kombu.MessageRedis priority 0 is now lowest and 9 highest, matching AMQP.
Beanstalk priority order is now reversed: 0 is lowest and 9 is highest, matching AMQP.
Security1
Sanitises the URL when include_password is false.
include_passwordPlatform5
Adds Python 3.8 support.
Drops support for Python 3.4.
Adds Python 3.7 support.
SQS adds support for Python 3.4.
kombu[sqs] now depends on boto3 instead of boto, adding Python 3.4+, FIFO queues, and avoiding broken endpoints file issues.
kombu[sqs]boto3botoAPI changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
export Message - added:
variable version_info
- removed:
export ERR - removed:
export Hub - removed:
export READ - removed:
export WRITE - removed:
export get_event_loop - removed:
export set_event_loop
- removed:
function callback_for(h, fd, flag, *default) - removed:
function repr_active(h) - removed:
function repr_events(h, events) - removed:
function repr_flag(flag) - removed:
function repr_readers(h) - removed:
function repr_writers(h)
- removed:
class Hub(object) - removed:
constructor Hub(timer=…) - removed:
field Hub.ERR - removed:
field Hub.READ - removed:
field Hub.WRITE - removed:
field Hub.on_close - removed:
function get_event_loop() - removed:
function set_event_loop(loop) - removed:
method Hub.add(fd, callback, flags, args=…, consolidate=…) - removed:
method Hub.add_reader(fds, callback, *args) - removed:
method Hub.add_writer(fds, callback, *args) - removed:
method Hub.call_at(when, callback, *args) - removed:
method Hub.call_later(delay, callback, *args) - removed:
method Hub.call_repeatedly(delay, callback, *args) - removed:
method Hub.call_soon(callback, *args) - removed:
method Hub.close(*args) - removed:
method Hub.create_loop(generator=…, sleep=…, min=…, next=…, Empty=…, StopIteration=…, KeyError=…, READ=…, WRITE=…, ERR=…) - removed:
method Hub.fire_timers(min_delay=…, max_delay=…, max_timers=…, propagate=…) - removed:
method Hub.remove(fd) - removed:
method Hub.remove_reader(fd) - removed:
method Hub.remove_writer(fd) - removed:
method Hub.repr_active() - removed:
method Hub.repr_events(events) - removed:
method Hub.reset() - removed:
method Hub.run_forever() - removed:
method Hub.run_once() - removed:
method Hub.stop() - removed:
property Hub.loop - removed:
property Hub.scheduler
- removed:
class DummyLock(object) - removed:
class LaxBoundedSemaphore(object) - removed:
constructor LaxBoundedSemaphore(value) - removed:
method LaxBoundedSemaphore.acquire(callback, *partial_args) - removed:
method LaxBoundedSemaphore.clear() - removed:
method LaxBoundedSemaphore.grow(n=…) - removed:
method LaxBoundedSemaphore.release() - removed:
method LaxBoundedSemaphore.shrink(n=…)
- removed:
class Entry(object) - removed:
class Timer(object) - removed:
constructor Entry(fun, args=…, kwargs=…) - removed:
constructor Timer(max_interval=…, on_error=…, **kwargs) - removed:
field Timer.Entry - removed:
field Timer.on_error - removed:
function to_timestamp(d, default_timezone=…) - removed:
method Entry.cancel() - removed:
method Timer.apply_entry(entry) - removed:
method Timer.call_after(secs, fun, args=…, kwargs=…, priority=…) - removed:
method Timer.call_at(eta, fun, args=…, kwargs=…, priority=…) - removed:
method Timer.call_repeatedly(secs, fun, args=…, kwargs=…, priority=…) - removed:
method Timer.cancel(tref) - removed:
method Timer.clear() - removed:
method Timer.enter_after(secs, entry, priority=…, time=…) - removed:
method Timer.enter_at(entry, eta=…, priority=…, time=…) - removed:
method Timer.handle_error(exc_info) - removed:
method Timer.stop() - removed:
property Timer.queue - removed:
property Timer.schedule
- added:
export ERR - added:
export Hub - added:
export READ - added:
export WRITE - added:
export get_event_loop - added:
export set_event_loop
- added:
function connect_sqs(aws_access_key_id=…, aws_secret_access_key=…, **kwargs)
- added:
class AsyncConnection(object) - added:
class AsyncHTTPSConnection(object) - added:
constructor AsyncConnection(sqs_connection, http_client=…, **kwargs) - added:
constructor AsyncHTTPSConnection(strict=…, timeout=…, http_client=…) - added:
field AsyncHTTPSConnection.Request - added:
field AsyncHTTPSConnection.Response - added:
field AsyncHTTPSConnection.body - added:
field AsyncHTTPSConnection.default_ports - added:
field AsyncHTTPSConnection.method - added:
field AsyncHTTPSConnection.path - added:
method AsyncConnection.get_http_connection() - added:
method AsyncHTTPSConnection.close() - added:
method AsyncHTTPSConnection.connect() - added:
method AsyncHTTPSConnection.endheaders() - added:
method AsyncHTTPSConnection.getrequest() - added:
method AsyncHTTPSConnection.getresponse(callback=…) - added:
method AsyncHTTPSConnection.putheader(header, value) - added:
method AsyncHTTPSConnection.putrequest(method, path) - added:
method AsyncHTTPSConnection.request(method, path, body=…, headers=…) - added:
method AsyncHTTPSConnection.send(data) - added:
method AsyncHTTPSConnection.set_debuglevel(level)
- added:
export AWSRequest - added:
export exceptions - added:
export get_response - added:
variable AWSRequest - added:
variable exceptions - added:
variable get_response
- added:
class AsyncSQSConnection(AsyncAWSQueryConnection) - added:
constructor AsyncSQSConnection(sqs_connection, debug=…, region=…, **kwargs) - added:
field AsyncSQSConnection.lookup - added:
method AsyncSQSConnection.add_permission(queue, label, aws_account_id, action_name, callback=…) - added:
method AsyncSQSConnection.change_message_visibility(queue, receipt_handle, visibility_timeout, callback=…) - added:
method AsyncSQSConnection.change_message_visibility_batch(queue, messages, callback=…) - added:
method AsyncSQSConnection.create_queue(queue_name, visibility_timeout=…, callback=…) - added:
method AsyncSQSConnection.delete_message(queue, receipt_handle, callback=…) - added:
method AsyncSQSConnection.delete_message_batch(queue, messages, callback=…) - added:
method AsyncSQSConnection.delete_message_from_handle(queue, receipt_handle, callback=…) - added:
method AsyncSQSConnection.delete_queue(queue, force_deletion=…, callback=…) - added:
method AsyncSQSConnection.get_all_queues(prefix=…, callback=…) - added:
method AsyncSQSConnection.get_dead_letter_source_queues(queue, callback=…) - added:
method AsyncSQSConnection.get_queue(queue_name, callback=…) - added:
method AsyncSQSConnection.get_queue_attributes(queue, attribute=…, callback=…) - added:
method AsyncSQSConnection.get_queue_url(queue) - added:
method AsyncSQSConnection.receive_message(queue, queue_url, number_messages=…, visibility_timeout=…, attributes=…, wait_time_seconds=…, callback=…) - added:
method AsyncSQSConnection.remove_permission(queue, label, callback=…) - added:
method AsyncSQSConnection.send_message(queue, message_content, delay_seconds=…, callback=…) - added:
method AsyncSQSConnection.send_message_batch(queue, messages, callback=…) - added:
method AsyncSQSConnection.set_queue_attribute(queue, attribute, value, callback=…)
- added:
variable boto3
- added:
class AsyncMessage(BaseAsyncMessage) - added:
class AsyncRawMessage(BaseAsyncMessage) - added:
class BaseAsyncMessage(Message) - added:
method AsyncMessage.encode(value)
- added:
class AsyncQueue - added:
constructor AsyncQueue(connection=…, url=…, message_class=…) - added:
field AsyncQueue.clear - added:
field AsyncQueue.count_slow - added:
field AsyncQueue.dump - added:
field AsyncQueue.load - added:
field AsyncQueue.load_from_file - added:
field AsyncQueue.load_from_filename - added:
field AsyncQueue.load_from_s3 - added:
field AsyncQueue.save - added:
field AsyncQueue.save_to_file - added:
field AsyncQueue.save_to_filename - added:
field AsyncQueue.save_to_s3 - added:
function list_first(rs) - added:
method AsyncQueue.add_permission(label, aws_account_id, action_name, callback=…) - added:
method AsyncQueue.change_message_visibility_batch(messages, callback=…) - added:
method AsyncQueue.count(page_size=…, vtimeout=…, callback=…, _attr=…) - added:
method AsyncQueue.delete(callback=…) - added:
method AsyncQueue.delete_message(message, callback=…) - added:
method AsyncQueue.delete_message_batch(messages, callback=…) - added:
method AsyncQueue.get_attributes(attributes=…, callback=…) - added:
method AsyncQueue.get_messages(num_messages=…, visibility_timeout=…, attributes=…, wait_time_seconds=…, callback=…) - added:
method AsyncQueue.get_timeout(callback=…, _attr=…) - added:
method AsyncQueue.read(visibility_timeout=…, wait_time_seconds=…, callback=…) - added:
method AsyncQueue.remove_permission(label, callback=…) - added:
method AsyncQueue.set_attribute(attribute, value, callback=…) - added:
method AsyncQueue.set_timeout(visibility_timeout, callback=…) - added:
method AsyncQueue.write(message, delay_seconds=…, callback=…) - added:
method AsyncQueue.write_batch(messages, callback=…)
- added:
function callback_for(h, fd, flag, *default) - added:
function repr_active(h) - added:
function repr_events(h, events) - added:
function repr_flag(flag) - added:
function repr_readers(h) - added:
function repr_writers(h)
- added:
export Headers - added:
export Request - added:
export Response - added:
function Client(hub=…, **kwargs)
- added:
class Headers(dict) - added:
class Request(object) - added:
class Response(object) - added:
constructor Request(url, method=…, on_ready=…, on_timeout=…, on_stream=…, on_prepare=…, on_header=…, headers=…, **kwargs) - added:
constructor Response(request, code, headers=…, buffer=…, effective_url=…, error=…, status=…) - added:
field Headers.complete - added:
field Request.auth_mode - added:
field Request.auth_password - added:
field Request.auth_username - added:
field Request.body - added:
field Request.ca_certs - added:
field Request.client_cert - added:
field Request.client_key - added:
field Request.connect_timeout - added:
field Request.follow_redirects - added:
field Request.max_redirects - added:
field Request.network_interface - added:
field Request.proxy_host - added:
field Request.proxy_password - added:
field Request.proxy_port - added:
field Request.proxy_username - added:
field Request.request_timeout - added:
field Request.use_gzip - added:
field Request.user_agent - added:
field Request.validate_cert - added:
method Request.then(callback, errback=…) - added:
method Response.raise_for_error() - added:
property Response.body - added:
property Response.content - added:
property Response.status_code
- added:
class CurlClient(BaseClient) - added:
constructor CurlClient(hub=…, max_clients=…) - added:
field CurlClient.Curl - added:
method CurlClient.add_request(request) - added:
method CurlClient.close() - added:
method CurlClient.on_readable(fd, _pycurl=…) - added:
method CurlClient.on_writable(fd, _pycurl=…)
- added:
class Hub(object) - added:
constructor Hub(timer=…) - added:
field Hub.ERR - added:
field Hub.READ - added:
field Hub.WRITE - added:
field Hub.on_close - added:
function get_event_loop() - added:
function set_event_loop(loop) - added:
method Hub.add(fd, callback, flags, args=…, consolidate=…) - added:
method Hub.add_reader(fds, callback, *args) - added:
method Hub.add_writer(fds, callback, *args) - added:
method Hub.call_at(when, callback, *args) - added:
method Hub.call_later(delay, callback, *args) - added:
method Hub.call_repeatedly(delay, callback, *args) - added:
method Hub.call_soon(callback, *args) - added:
method Hub.close(*args) - added:
method Hub.create_loop(generator=…, sleep=…, min=…, next=…, Empty=…, StopIteration=…, KeyError=…, READ=…, WRITE=…, ERR=…) - added:
method Hub.fire_timers(min_delay=…, max_delay=…, max_timers=…, propagate=…) - added:
method Hub.on_callback_error(callback, exc) - added:
method Hub.remove(fd) - added:
method Hub.remove_reader(fd) - added:
method Hub.remove_writer(fd) - added:
method Hub.repr_active() - added:
method Hub.repr_events(events) - added:
method Hub.reset() - added:
method Hub.run_forever() - added:
method Hub.run_once() - added:
method Hub.stop() - added:
property Hub.loop - added:
property Hub.poller - added:
property Hub.scheduler
- added:
class DummyLock(object) - added:
class LaxBoundedSemaphore(object) - added:
constructor LaxBoundedSemaphore(value) - added:
method LaxBoundedSemaphore.acquire(callback, *partial_args, **partial_kwargs) - added:
method LaxBoundedSemaphore.clear() - added:
method LaxBoundedSemaphore.grow(n=…) - added:
method LaxBoundedSemaphore.release() - added:
method LaxBoundedSemaphore.shrink(n=…)
- added:
class Entry(object) - added:
class Timer(object) - added:
constructor Entry(fun, args=…, kwargs=…) - added:
constructor Timer(max_interval=…, on_error=…, **kwargs) - added:
field Timer.Entry - added:
field Timer.on_error - added:
function to_timestamp(d, default_timezone=…, time=…) - added:
method Entry.cancel() - added:
method Timer.apply_entry(entry) - added:
method Timer.call_after(secs, fun, args=…, kwargs=…, priority=…) - added:
method Timer.call_at(eta, fun, args=…, kwargs=…, priority=…) - added:
method Timer.call_repeatedly(secs, fun, args=…, kwargs=…, priority=…) - added:
method Timer.cancel(tref) - added:
method Timer.clear() - added:
method Timer.enter_after(secs, entry, priority=…, time=…) - added:
method Timer.enter_at(entry, eta=…, priority=…, time=…) - added:
method Timer.handle_error(exc_info) - added:
method Timer.stop() - added:
property Entry.cancelled - added:
property Timer.queue - added:
property Timer.schedule
- changed:
constructor Broadcast(name=…, queue=…, auto_delete=…, exchange=…, alias=…, **kwargs) → constructor Broadcast(name=…, queue=…, unique=…, auto_delete=…, exchange=…, alias=…, **kwargs)
- changed:
constructor ChannelPool(connection, limit=…, preload=…) → constructor ChannelPool(connection, limit=…, **kwargs) - changed:
constructor ConnectionPool(connection, limit=…, preload=…) → constructor ConnectionPool(connection, limit=…, **kwargs) - changed:
method Connection.ChannelPool(limit=…, preload=…) → method Connection.ChannelPool(limit=…, **kwargs) - changed:
method Connection.Pool(limit=…, preload=…) → method Connection.Pool(limit=…, **kwargs) - changed:
method Connection.SimpleBuffer(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) → method Connection.SimpleBuffer(name, no_ack=…, queue_opts=…, queue_args=…, exchange_opts=…, channel=…, **kwargs) - changed:
method Connection.SimpleQueue(name, no_ack=…, queue_opts=…, exchange_opts=…, channel=…, **kwargs) → method Connection.SimpleQueue(name, no_ack=…, queue_opts=…, queue_args=…, exchange_opts=…, channel=…, **kwargs) - changed:
method Connection.ensure_connection(errback=…, max_retries=…, interval_start=…, interval_step=…, interval_max=…, callback=…) → method Connection.ensure_connection(*args, **kwargs) - changed:
method Connection.switch(url) → method Connection.switch(conn_str) - added:
field Connection.resolve_aliases - added:
field ConnectionPool.close_after_fork - added:
method Connection.supports_exchange_type(exchange_type)
- changed:
method Exchange.Message(body, delivery_mode=…, priority=…, content_type=…, content_encoding=…, properties=…, headers=…) → method Exchange.Message(body, delivery_mode=…, properties=…, **kwargs) - changed:
method Exchange.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…, **kwargs) → method Exchange.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…, channel=…, **kwargs) - changed:
method Exchange.declare(nowait=…, passive=…) → method Exchange.declare(nowait=…, passive=…, channel=…) - changed:
method Exchange.unbind_from(source=…, routing_key=…, nowait=…, arguments=…) → method Exchange.unbind_from(source=…, routing_key=…, nowait=…, arguments=…, channel=…) - changed:
method Queue.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…) → method Queue.bind_to(exchange=…, routing_key=…, arguments=…, nowait=…, channel=…) - changed:
method Queue.declare(nowait=…) → method Queue.declare(nowait=…, channel=…) - changed:
method Queue.queue_bind(nowait=…) → method Queue.queue_bind(nowait=…, channel=…) - changed:
method Queue.queue_declare(nowait=…, passive=…) → method Queue.queue_declare(nowait=…, passive=…, channel=…) - changed:
method Queue.queue_unbind(arguments=…, nowait=…) → method Queue.queue_unbind(arguments=…, nowait=…, channel=…) - changed:
method Queue.unbind_from(exchange=…, routing_key=…, arguments=…, nowait=…) → method Queue.unbind_from(exchange=…, routing_key=…, arguments=…, nowait=…, channel=…) - changed:
method binding.bind(entity, nowait=…) → method binding.bind(entity, nowait=…, channel=…) - changed:
method binding.unbind(entity, nowait=…) → method binding.unbind(entity, nowait=…, channel=…) - added:
field Exchange.no_declare - added:
function maybe_delivery_mode(v, modes=…, default=…)
- removed:
variable TimeoutError - added:
class HttpError(Exception) - added:
class InconsistencyError(ConnectionError) - added:
class KombuError(Exception) - added:
class OperationalError(KombuError) - added:
constructor HttpError(code, message=…, response=…) - added:
export TimeoutError
- removed:
class WhateverIO(StringIO) - removed:
class timespec(ctypes.Structure) - removed:
function exec_(code, globs=…, locs=…) - removed:
function items(d) - removed:
function keys(d) - removed:
function nextfun(it) - removed:
function reraise(tp, value, tb=…) - removed:
function values(d) - removed:
function with_metaclass(Type, skip_attrs=…) - removed:
method WhateverIO.write(data) - removed:
variable BytesIO - removed:
variable CLOCK_MONOTONIC - removed:
variable CoreServices - removed:
variable PY3 - removed:
variable SYSTEM - removed:
variable WhateverIO - removed:
variable absolute_to_nanoseconds - removed:
variable bytes_t - removed:
variable clock_gettime - removed:
variable ctypes - removed:
variable exec_ - removed:
variable libSystem - removed:
variable librt - removed:
variable long_t - removed:
variable mach_absolute_time - removed:
variable map - removed:
variable module_name_t - removed:
variable monotonic - removed:
variable open_fqdn - removed:
variable range - removed:
variable reload - removed:
variable string - removed:
variable string_t - removed:
variable text_t - removed:
variable zip
- added:
class MatcherNotInstalled(Exception) - added:
class MatcherRegistry(object) - added:
constructor MatcherRegistry() - added:
field MatcherRegistry.MatcherNotInstalled - added:
field MatcherRegistry.matcher_pattern_first - added:
function register_glob() - added:
function register_pcre() - added:
method MatcherRegistry.match(data, pattern, matcher=…, matcher_kwargs=…) - added:
method MatcherRegistry.register(name, matcher) - added:
method MatcherRegistry.unregister(name) - added:
variable match - added:
variable register - added:
variable registry - added:
variable unregister
- removed:
variable ACK_STATES - changed:
constructor Message(channel, body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, accept=…, **kwargs) → constructor Message(body=…, delivery_tag=…, content_type=…, content_encoding=…, delivery_info=…, properties=…, headers=…, postencode=…, accept=…, channel=…, **kwargs) - changed:
method Message.ack() → method Message.ack(multiple=…) - changed:
method Message.ack_log_error(logger, errors) → method Message.ack_log_error(logger, errors, multiple=…)
- removed:
method Consumer.add_queue_from_dict(queue, **options) - changed:
constructor Consumer(channel, queues=…, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…, on_message=…, accept=…, tag_prefix=…) → constructor Consumer(channel, queues=…, no_ack=…, auto_declare=…, callbacks=…, on_decode_error=…, on_message=…, accept=…, prefetch_count=…, tag_prefix=…) - added:
field Consumer.prefetch_count - added:
property Consumer.queues
- changed:
method ConsumerMixin.run(_tokens=…) → method ConsumerMixin.run(_tokens=…, **kwargs) - added:
class ConsumerProducerMixin(ConsumerMixin) - added:
method ConsumerProducerMixin.on_consume_end(connection, channel) - added:
property ConsumerProducerMixin.producer - added:
property ConsumerProducerMixin.producer_connection
- changed:
constructor Mailbox(namespace, type=…, connection=…, clock=…, accept=…, serializer=…) → constructor Mailbox(namespace, type=…, connection=…, clock=…, accept=…, serializer=…, producer_pool=…, queue_ttl=…, queue_expires=…, reply_queue_ttl=…, reply_queue_expires=…) - added:
method Mailbox.producer_or_acquire(producer=…, channel=…) - added:
property Mailbox.producer_pool
- changed:
constructor PoolGroup(limit=…) → constructor PoolGroup(limit=…, close_after_fork=…) - changed:
function set_limit(limit, force=…, reset_after=…) → function set_limit(limit, force=…, reset_after=…, ignore_errors=…) - added:
field ProducerPool.close_after_fork
- added:
class LifoQueue(_LifoQueue) - added:
class Resource(object) - added:
constructor Resource(limit=…, preload=…, close_after_fork=…) - added:
field Resource.LimitExceeded - added:
field Resource.close_after_fork - added:
method Resource.acquire(*args, **kwargs) - added:
method Resource.close_resource(resource) - added:
method Resource.collect_resource(resource) - added:
method Resource.force_close_all() - added:
method Resource.prepare(resource) - added:
method Resource.release(resource) - added:
method Resource.release_resource(resource) - added:
method Resource.replace(resource) - added:
method Resource.resize(limit, force=…, ignore_errors=…, reset=…) - added:
method Resource.setup() - added:
property Resource.limit
- changed:
constructor SimpleQueue(channel, name, no_ack=…, queue_opts=…, exchange_opts=…, serializer=…, compression=…, **kwargs) → constructor SimpleQueue(channel, name, no_ack=…, queue_opts=…, queue_args=…, exchange_opts=…, serializer=…, compression=…, **kwargs) - added:
field SimpleQueue.queue_args
- removed:
function detect_environment()
- removed:
class Table(Domain) - removed:
field Channel.Table - removed:
method Channel.exchange_delete(exchange, **kwargs) - removed:
method Channel.get_exchanges() - removed:
method Channel.get_table(exchange) - removed:
method Channel.queue_bind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - removed:
method Table.create_binding(queue) - removed:
method Table.exchange_delete(exchange) - removed:
method Table.get_exchanges() - removed:
method Table.get_item(item_name) - removed:
method Table.get_queue(queue) - removed:
method Table.queue_bind(exchange, routing_key, pattern, queue) - removed:
method Table.queue_delete(queue) - removed:
method Table.routes_for(exchange) - removed:
method Table.select(query=…, next_token=…, consistent_read=…, max_items=…) - removed:
property Channel.sdb - removed:
property Channel.sqs - removed:
property Channel.table - removed:
variable BOTO_VERSION - removed:
variable W_LONG_POLLING - changed:
method Channel.basic_ack(delivery_tag) → method Channel.basic_ack(delivery_tag, multiple=…) - changed:
method Channel.drain_events(timeout=…) → method Channel.drain_events(timeout=…, callback=…, **kwargs) - added:
class UndefinedQueueException(Exception) - added:
field Transport.implements - added:
method Channel.asynsqs(queue=…) - added:
method Channel.canonical_queue_name(queue_name) - added:
method Channel.new_sqs_client(region, access_key_id, secret_access_key) - added:
method Channel.sqs(queue=…) - added:
property Channel.endpoint_url - added:
property Channel.is_secure - added:
property Channel.port - added:
property Channel.predefined_queues - added:
property Channel.regioninfo - added:
property Transport.default_connection_params
- removed:
class Channel(_Channel, base.StdChannel) - removed:
class Connection(amqp.Connection) - removed:
class Message(base.Message) - removed:
class NA(object) - removed:
class NAx(object) - removed:
class SSLError(Exception) - removed:
class SSLTransport(transport.SSLTransport) - removed:
class TCPTransport(transport.TCPTransport) - removed:
class Transport(base.Transport) - removed:
constructor Channel(*args, **kwargs) - removed:
constructor Connection(*args, **kwargs) - removed:
constructor Message(channel, msg, **kwargs) - removed:
constructor SSLTransport(host, connect_timeout, ssl) - removed:
constructor Transport(client, **kwargs) - removed:
field Channel.Message - removed:
field Channel.events - removed:
field Connection.connected - removed:
field Transport.Connection - removed:
field Transport.channel_errors - removed:
field Transport.connection_errors - removed:
field Transport.default_port - removed:
field Transport.driver_name - removed:
field Transport.driver_type - removed:
field Transport.supports_ev - 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(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - removed:
method Connection.channel(channel_id=…) - removed:
method Connection.drain_events(timeout=…) - removed:
method Connection.read_timeout(timeout=…) - removed:
method SSLTransport.read_frame() - removed:
method TCPTransport.read_frame() - 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.get_manager(*args, **kwargs) - removed:
method Transport.is_alive(connection) - removed:
method Transport.register_with_event_loop(connection, loop) - removed:
method Transport.verify_connection(connection) - removed:
property Transport.default_connection_params - removed:
variable AMQPChannelException - removed:
variable AMQPConnectionException - removed:
variable DEFAULT_PORT - removed:
variable HAS_MSG_PEEK - removed:
variable amqp - removed:
variable transport
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
field Channel.default_peek_lock - added:
field Channel.default_visibility_timeout - added:
field Channel.default_wait_time_seconds - added:
field Channel.domain_format - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.polling_interval - added:
method Channel.entity_name(name, table=…) - added:
property Channel.conninfo - added:
property Channel.peek_lock - added:
property Channel.queue_name_prefix - added:
property Channel.queue_service - added:
property Channel.transport_options - added:
property Channel.visibility_timeout - added:
property Channel.wait_time_seconds - added:
variable CHARS_REPLACE_TABLE - added:
variable Message - added:
variable Queue - added:
variable ServiceBusService
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
field Channel.domain_format - added:
field Channel.no_ack - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.polling_interval - added:
method Channel.basic_consume(queue, no_ack, *args, **kwargs) - added:
method Channel.entity_name(name, table=…) - added:
property Channel.conninfo - added:
property Channel.queue_name_prefix - added:
property Channel.queue_service - added:
property Channel.transport_options - added:
variable CHARS_REPLACE_TABLE - added:
variable QueueService
- removed:
field Transport.supports_ev - removed:
field Transport.supports_heartbeats - changed:
method Transport.register_with_event_loop(loop) → method Transport.register_with_event_loop(connection, loop) - changed:
method Transport.unregister_from_event_loop(loop) → method Transport.unregister_from_event_loop(connection, loop) - added:
field Transport.implements - added:
method StdChannel.prepare_queue_arguments(arguments, **kwargs) - added:
property Transport.supports_ev - added:
property Transport.supports_heartbeats
- removed:
class Channel(virtual.Channel) - removed:
class Transport(virtual.Transport) - removed:
constructor Transport(*args, **kwargs) - removed:
field Transport.Channel - removed:
field Transport.channel_errors - removed:
field Transport.connection_errors - removed:
field Transport.default_port - removed:
field Transport.driver_name - removed:
field Transport.driver_type - removed:
field Transport.polling_interval - removed:
method Channel.close() - removed:
method Transport.driver_version() - removed:
property Channel.client - removed:
variable DEFAULT_PORT - removed:
variable beanstalkc
- added:
class Channel(virtual.Channel) - added:
class LockError(Exception) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
constructor Transport(*args, **kwargs) - added:
field Channel.index - added:
field Channel.prefix - added:
field Channel.session_ttl - added:
field Channel.timeout - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
method Transport.driver_version() - added:
method Transport.verify_connection(connection) - added:
property Channel.lock_name - added:
variable DEFAULT_HOST - added:
variable DEFAULT_PORT - added:
variable consul - added:
variable logger
- removed:
class Channel(virtual.Channel) - removed:
class Transport(virtual.Transport) - removed:
constructor Transport(*args, **kwargs) - 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.driver_name - removed:
field Transport.driver_type - removed:
field Transport.polling_interval - removed:
function create_message_view(db) - removed:
method Transport.driver_version() - removed:
property Channel.client - removed:
variable DEFAULT_DATABASE - removed:
variable DEFAULT_PORT - removed:
variable couchdb
- removed:
class Channel(virtual.Channel) - removed:
class KombuAppConfig(AppConfig) - removed:
class Transport(virtual.Transport) - removed:
export Empty - removed:
export bytes_to_str - removed:
export cached_property - removed:
export symbol_by_name - removed:
export virtual - removed:
field Channel.queue_model - removed:
field KombuAppConfig.label - removed:
field KombuAppConfig.name - removed:
field KombuAppConfig.verbose_name - removed:
field Transport.Channel - removed:
field Transport.channel_errors - removed:
field Transport.default_port - removed:
field Transport.driver_name - removed:
field Transport.driver_type - removed:
field Transport.polling_interval - removed:
method Channel.basic_consume(queue, *args, **kwargs) - removed:
method Channel.refresh_connection() - removed:
method Transport.driver_version() - removed:
property Channel.Queue - removed:
variable POLLING_INTERVAL - removed:
variable VERSION - removed:
variable default_app_config
- removed:
class Command(BaseCommand) - removed:
field Command.requires_model_validation - removed:
function pluralize(desc, value) - removed:
method Command.handle(*args, **options)
- removed:
class MessageManager(models.Manager) - removed:
class QueueManager(models.Manager) - removed:
field MessageManager.cleanup_every - removed:
function commit_on_success(fun) - removed:
function select_for_update(qs) - removed:
method MessageManager.cleanup() - removed:
method MessageManager.connection_for_write() - removed:
method MessageManager.pop() - removed:
method QueueManager.fetch(queue_name) - removed:
method QueueManager.publish(queue_name, payload) - removed:
method QueueManager.purge(queue_name) - removed:
method QueueManager.size(queue_name) - removed:
variable commit_on_success - removed:
variable connections - removed:
variable router
- removed:
variable SOUTH_ERROR_MESSAGE
- removed:
class Message(models.Model) - removed:
class Message.Meta - removed:
class Queue(models.Model) - removed:
class Queue.Meta - removed:
field Message.Meta.app_label - removed:
field Message.Meta.db_table - removed:
field Message.Meta.verbose_name - removed:
field Message.Meta.verbose_name_plural - removed:
field Message.objects - removed:
field Message.payload - removed:
field Message.queue - removed:
field Message.sent_at - removed:
field Message.visible - removed:
field Queue.Meta.app_label - removed:
field Queue.Meta.db_table - removed:
field Queue.Meta.verbose_name - removed:
field Queue.Meta.verbose_name_plural - removed:
field Queue.name - removed:
field Queue.objects
- added:
class Channel(virtual.Channel) - added:
class Transport(virtual.Transport) - added:
constructor Channel(*args, **kwargs) - added:
constructor Transport(*args, **kwargs) - added:
field Channel.index - added:
field Channel.lock_ttl - added:
field Channel.prefix - added:
field Channel.session_ttl - added:
field Channel.timeout - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.implements - added:
field Transport.polling_interval - added:
method Transport.driver_version() - added:
method Transport.verify_connection(connection) - added:
property Channel.lock_value - added:
variable DEFAULT_HOST - added:
variable DEFAULT_PORT - added:
variable etcd - added:
variable logger
- removed:
field Transport.supports_ev - added:
field Transport.implements - added:
method Channel.prepare_queue_arguments(arguments, **kwargs)
- added:
field Channel.events - added:
field Transport.implements
- removed:
class CursorType(object) - removed:
method Channel.create_broadcast_cursor(exchange, routing_key, pattern, queue) - removed:
method Channel.get_broadcast() - removed:
method Channel.get_broadcast_cursor(queue) - removed:
method Channel.get_messages() - removed:
method Channel.get_routing() - removed:
variable DEFAULT_BROADCAST_COLLECTION - removed:
variable DEFAULT_HOST - removed:
variable DEFAULT_MESSAGES_COLLECTION - removed:
variable DEFAULT_PORT - removed:
variable DEFAULT_ROUTING_COLLECTION - added:
field Channel.broadcast_collection - added:
field Channel.calc_queue_size - added:
field Channel.capped_queue_size - added:
field Channel.connect_timeout - added:
field Channel.default_database - added:
field Channel.default_hostname - added:
field Channel.default_port - added:
field Channel.from_transport_options - added:
field Channel.messages_collection - added:
field Channel.queues_collection - added:
field Channel.routing_collection - added:
field Channel.ssl - added:
field Channel.ttl - added:
field Transport.implements - added:
method Channel.get_now() - added:
method Channel.prepare_queue_arguments(arguments, **kwargs) - added:
property Channel.broadcast - added:
property Channel.messages - added:
property Channel.queues - added:
property Channel.routing - added:
variable E_NO_TTL_INDEXES - added:
variable E_SERVER_VERSION
- removed:
field Transport.supports_ev - removed:
field Transport.supports_heartbeats - changed:
constructor Message(channel, msg, **kwargs) → constructor Message(msg, channel=…, **kwargs) - added:
class SSLTransport(Transport) - added:
constructor SSLTransport(*args, **kwargs) - added:
field Transport.implements - added:
method Channel.prepare_queue_arguments(arguments, **kwargs)
- added:
class KombuBroker(object) - added:
constructor KombuBroker() - added:
method Channel.close() - added:
method KombuBroker.delete(queue) - added:
method KombuBroker.get(queue) - added:
method KombuBroker.get_queue_names() - added:
method KombuBroker.has_queue(queue) - added:
method KombuBroker.new_queue(queue) - added:
method KombuBroker.purge(queue) - added:
method KombuBroker.put(queue, message) - added:
method KombuBroker.size(queue) - added:
variable E_NAMESERVER - added:
variable SerializerBase - added:
variable logger
- removed:
field Transport.supports_ev - removed:
variable PY3 - changed:
method Channel.basic_ack(delivery_tag) → method Channel.basic_ack(delivery_tag, multiple=…) - added:
field Transport.implements
- added:
class Channel(virtual.Channel) - added:
class MultiChannelPoller(object) - added:
class MutexHeld(Exception) - added:
class QoS(virtual.QoS) - added:
class SentinelChannel(Channel) - added:
class SentinelTransport(Transport) - 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.connection_class - added:
field Channel.fanout_patterns - added:
field Channel.fanout_prefix - added:
field Channel.from_transport_options - added:
field Channel.health_check_interval - added:
field Channel.keyprefix_fanout - added:
field Channel.keyprefix_queue - added:
field Channel.max_connections - added:
field Channel.priority_steps - added:
field Channel.queue_order_strategy - added:
field Channel.retry_on_timeout - added:
field Channel.sep - added:
field Channel.socket_connect_timeout - added:
field Channel.socket_keepalive - added:
field Channel.socket_keepalive_options - 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.after_read - added:
field MultiChannelPoller.eventflags - added:
field QoS.restore_at_shutdown - added:
field SentinelChannel.connection_class - added:
field SentinelChannel.from_transport_options - added:
field SentinelTransport.Channel - added:
field SentinelTransport.default_port - added:
field Transport.Channel - added:
field Transport.default_port - added:
field Transport.driver_name - added:
field Transport.driver_type - added:
field Transport.implements - added:
field Transport.polling_interval - added:
function Mutex(client, name, expire) - added:
function get_redis_ConnectionError() - added:
function get_redis_error_classes() - 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(callback, timeout=…) - added:
method MultiChannelPoller.handle_event(fileno, event) - added:
method MultiChannelPoller.maybe_check_subclient_health() - added:
method MultiChannelPoller.maybe_restore_messages() - added:
method MultiChannelPoller.on_poll_init(poller) - added:
method MultiChannelPoller.on_poll_start() - added:
method MultiChannelPoller.on_readable(fileno) - added:
method QoS.ack(delivery_tag) - added:
method QoS.append(message, delivery_tag) - added:
method QoS.pipe_or_acquire(pipe=…, client=…) - added:
method QoS.reject(delivery_tag, requeue=…) - added:
method QoS.restore_by_tag(tag, client=…, leftmost=…) - added:
method QoS.restore_unacked(client=…) - added:
method QoS.restore_visible(start=…, num=…, interval=…) - added:
method Transport.driver_version() - added:
method Transport.on_readable(fileno) - added:
method Transport.register_with_event_loop(connection, loop) - added:
property Channel.active_queues - added:
property Channel.async_pool - 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_HEALTH_CHECK_INTERVAL - added:
variable DEFAULT_PORT - added:
variable NO_ROUTE_ERROR - added:
variable PRIORITY_STEPS - added:
variable crit - added:
variable error_classes_t - added:
variable logger - added:
variable redis - added:
variable sentinel - added:
variable warn
- removed:
class AbstractChannel(object) - removed:
class Base64(object) - removed:
class BrokerState(object) - removed:
class Channel(AbstractChannel, base.StdChannel) - removed:
class Management(base.Management) - removed:
class Message(base.Message) - removed:
class NotEquivalentError(Exception) - removed:
class QoS(object) - removed:
class Transport(base.Transport) - removed:
class UndeliverableWarning(UserWarning) - removed:
constructor BrokerState(exchanges=…, bindings=…) - removed:
constructor Channel(connection, **kwargs) - removed:
constructor Management(transport) - removed:
constructor Message(channel, payload, **kwargs) - removed:
constructor QoS(channel, prefetch_count=…) - removed:
constructor Transport(client, **kwargs) - removed:
export ChannelError - removed:
export FairCycle - removed:
export OrderedDict - removed:
export ResourceError - removed:
export STANDARD_EXCHANGE_TYPES - removed:
export base - removed:
export bytes_to_str - removed:
export emergency_dump_state - removed:
export items - removed:
export kwdict - removed:
export monotonic - removed:
export say - removed:
export str_to_bytes - removed:
export uuid - removed:
field BrokerState.bindings - removed:
field BrokerState.exchanges - removed:
field Channel.Message - removed:
field Channel.QoS - removed:
field Channel.body_encoding - removed:
field Channel.codecs - removed:
field Channel.deadletter_queue - removed:
field Channel.do_restore - removed:
field Channel.exchange_types - removed:
field Channel.from_transport_options - removed:
field Channel.supports_fanout - removed:
field QoS.prefetch_count - removed:
field QoS.restore_at_shutdown - removed:
field Transport.Channel - removed:
field Transport.Cycle - removed:
field Transport.Management - removed:
field Transport.channel_max - removed:
field Transport.channels - removed:
field Transport.cycle - removed:
field Transport.default_port - removed:
field Transport.polling_interval - removed:
field Transport.state - removed:
method Base64.decode(s) - removed:
method Base64.encode(s) - removed:
method BrokerState.clear() - removed:
method Channel.after_reply_message_received(queue) - 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, no_ack=…, **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.decode_body(body, encoding=…) - removed:
method Channel.drain_events(timeout=…) - removed:
method Channel.encode_body(body, encoding=…) - removed:
method Channel.exchange_bind(destination, source=…, routing_key=…, nowait=…, arguments=…) - removed:
method Channel.exchange_declare(exchange=…, type=…, durable=…, auto_delete=…, arguments=…, nowait=…, passive=…) - removed:
method Channel.exchange_delete(exchange, if_unused=…, nowait=…) - removed:
method Channel.exchange_unbind(destination, source=…, routing_key=…, nowait=…, arguments=…) - removed:
method Channel.flow(active=…) - removed:
method Channel.get_exchanges() - removed:
method Channel.get_table(exchange) - removed:
method Channel.list_bindings() - removed:
method Channel.message_to_python(raw_message) - removed:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - removed:
method Channel.queue_bind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - removed:
method Channel.queue_declare(queue=…, passive=…, **kwargs) - removed:
method Channel.queue_delete(queue, if_unused=…, if_empty=…, **kwargs) - removed:
method Channel.queue_purge(queue, **kwargs) - removed:
method Channel.queue_unbind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - removed:
method Channel.typeof(exchange, default=…) - removed:
method Management.close() - removed:
method Management.get_bindings() - removed:
method Message.serializable() - removed:
method QoS.ack(delivery_tag) - removed:
method QoS.append(message, delivery_tag) - removed:
method QoS.can_consume() - removed:
method QoS.can_consume_max_estimate() - removed:
method QoS.get(delivery_tag) - removed:
method QoS.reject(delivery_tag, requeue=…) - removed:
method QoS.restore_unacked() - removed:
method QoS.restore_unacked_once() - removed:
method QoS.restore_visible(*args, **kwargs) - removed:
method Transport.close_channel(channel) - removed:
method Transport.close_connection(connection) - removed:
method Transport.create_channel(connection) - removed:
method Transport.drain_events(connection, timeout=…) - removed:
method Transport.establish_connection() - removed:
property Channel.cycle - removed:
property Channel.qos - removed:
property Channel.state - removed:
property Transport.default_connection_params - removed:
variable ARRAY_TYPE_H - removed:
variable NOT_EQUIVALENT_FMT - removed:
variable UNDELIVERABLE_FMT - added:
export AbstractChannel - added:
export Base64 - added:
export BrokerState - added:
export Channel - added:
export Management - added:
export Message - added:
export NotEquivalentError - added:
export QoS - added:
export Transport - added:
export UndeliverableWarning - added:
export binding_key_t - added:
export queue_binding_t
- added:
class AbstractChannel(object) - added:
class Base64(object) - added:
class BrokerState(object) - added:
class Channel(AbstractChannel, base.StdChannel) - added:
class Management(base.Management) - added:
class Message(base.Message) - added:
class NotEquivalentError(Exception) - added:
class QoS(object) - added:
class Transport(base.Transport) - added:
class UndeliverableWarning(UserWarning) - added:
constructor BrokerState(exchanges=…) - added:
constructor Channel(connection, **kwargs) - added:
constructor Management(transport) - added:
constructor Message(payload, channel=…, **kwargs) - added:
constructor QoS(channel, prefetch_count=…) - added:
constructor Transport(client, **kwargs) - added:
field BrokerState.bindings - added:
field BrokerState.exchanges - added:
field BrokerState.queue_index - added:
field Channel.Message - added:
field Channel.QoS - added:
field Channel.body_encoding - added:
field Channel.codecs - added:
field Channel.deadletter_queue - added:
field Channel.default_priority - added:
field Channel.do_restore - added:
field Channel.exchange_types - added:
field Channel.from_transport_options - added:
field Channel.max_priority - added:
field Channel.min_priority - added:
field Channel.supports_fanout - added:
field QoS.prefetch_count - added:
field QoS.restore_at_shutdown - added:
field Transport.Channel - added:
field Transport.Cycle - added:
field Transport.Management - added:
field Transport.channel_max - added:
field Transport.channels - added:
field Transport.cycle - added:
field Transport.default_port - added:
field Transport.implements - added:
field Transport.polling_interval - added:
field Transport.state - added:
method Base64.decode(s) - added:
method Base64.encode(s) - added:
method BrokerState.binding_declare(queue, exchange, routing_key, arguments) - added:
method BrokerState.binding_delete(queue, exchange, routing_key) - added:
method BrokerState.clear() - added:
method BrokerState.has_binding(queue, exchange, routing_key) - added:
method BrokerState.queue_bindings(queue) - added:
method BrokerState.queue_bindings_delete(queue) - added:
method Channel.after_reply_message_received(queue) - added:
method Channel.basic_ack(delivery_tag, multiple=…) - 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, no_ack=…, **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.decode_body(body, encoding=…) - added:
method Channel.drain_events(timeout=…, callback=…) - added:
method Channel.encode_body(body, encoding=…) - added:
method Channel.exchange_bind(destination, source=…, routing_key=…, nowait=…, arguments=…) - added:
method Channel.exchange_declare(exchange=…, type=…, durable=…, auto_delete=…, arguments=…, nowait=…, passive=…) - added:
method Channel.exchange_delete(exchange, if_unused=…, nowait=…) - added:
method Channel.exchange_unbind(destination, source=…, routing_key=…, nowait=…, arguments=…) - added:
method Channel.flow(active=…) - added:
method Channel.get_exchanges() - added:
method Channel.get_table(exchange) - added:
method Channel.list_bindings() - added:
method Channel.message_to_python(raw_message) - added:
method Channel.prepare_message(body, priority=…, content_type=…, content_encoding=…, headers=…, properties=…) - added:
method Channel.queue_bind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - added:
method Channel.queue_declare(queue=…, passive=…, **kwargs) - added:
method Channel.queue_delete(queue, if_unused=…, if_empty=…, **kwargs) - added:
method Channel.queue_purge(queue, **kwargs) - added:
method Channel.queue_unbind(queue, exchange=…, routing_key=…, arguments=…, **kwargs) - added:
method Channel.typeof(exchange, default=…) - added:
method Management.close() - added:
method Management.get_bindings() - 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.can_consume_max_estimate() - added:
method QoS.get(delivery_tag) - added:
method QoS.reject(delivery_tag, requeue=…) - added:
method QoS.restore_unacked() - added:
method QoS.restore_unacked_once(stderr=…) - added:
method QoS.restore_visible(*args, **kwargs) - 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:
method Transport.on_message_ready(channel, message, queue) - added:
property Channel.cycle - added:
property Channel.qos - added:
property Channel.state - added:
property Transport.default_connection_params - added:
variable ARRAY_TYPE_H - added:
variable NOT_EQUIVALENT_FMT - added:
variable RESTORE_PANIC_FMT - added:
variable RESTORING_FMT - added:
variable UNDELIVERABLE_FMT - added:
variable W_NO_CONSUMERS - added:
variable binding_key_t - added:
variable logger - added:
variable queue_binding_t
- removed:
class FairCycle(object) - removed:
constructor FairCycle(fun, resources, predicate=…) - removed:
method FairCycle.close() - removed:
method FairCycle.get(**kwargs)
- removed:
class Channel(virtual.Channel) - removed:
class Client(object) - removed:
class MultiChannelPoller(object) - removed:
class Transport(virtual.Transport) - removed:
constructor Channel(*args, **kwargs) - removed:
constructor Client(uri=…, port=…, hwm=…, swap_size=…, enable_sink=…, context=…) - removed:
constructor MultiChannelPoller() - removed:
constructor Transport(*args, **kwargs) - removed:
field Channel.Client - removed:
field Channel.enable_sink - removed:
field Channel.from_transport_options - removed:
field Channel.hwm - removed:
field Channel.port_incr - removed:
field Channel.swap_size - removed:
field MultiChannelPoller.eventflags - removed:
field Transport.Channel - removed:
field Transport.can_parse_url - removed:
field Transport.connection_errors - removed:
field Transport.default_port - removed:
field Transport.driver_name - removed:
field Transport.driver_type - removed:
field Transport.polling_interval - removed:
field Transport.supports_ev - removed:
method Channel.close() - removed:
method Client.close() - removed:
method Client.connect(endpoint) - removed:
method Client.get(queue=…, timeout=…) - removed:
method Client.put(queue, message, **kwargs) - removed:
method MultiChannelPoller.add(channel) - removed:
method MultiChannelPoller.close() - removed:
method MultiChannelPoller.discard(channel) - removed:
method MultiChannelPoller.get(timeout=…) - removed:
method MultiChannelPoller.on_poll_start() - removed:
method MultiChannelPoller.on_readable(fileno) - removed:
method Transport.close_connection(connection) - removed:
method Transport.drain_events(connection, timeout=…) - removed:
method Transport.driver_version() - removed:
method Transport.establish_connection() - removed:
method Transport.on_readable(fileno) - removed:
method Transport.register_with_event_loop(connection, loop) - removed:
property Channel.client - removed:
property Client.connection - removed:
property MultiChannelPoller.fds - removed:
property Transport.context - removed:
variable DEFAULT_HWM - removed:
variable DEFAULT_INCR - removed:
variable DEFAULT_PORT - removed:
variable ZMQError - removed:
variable dumps - removed:
variable loads - removed:
variable logger - removed:
variable zmq
- removed:
variable MAX_PRIORITY - added:
constructor Channel(connection, **kwargs)
- 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 fileno(f) - removed:
function fxrange(start=…, stop=…, step=…, repeatlast=…) - removed:
function fxrangemax(start=…, stop=…, step=…, max=…) - removed:
function kwdict(kwargs) - removed:
function maybe_fileno(f) - removed:
function maybe_list(v) - removed:
function nested(*managers) - 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=…, callback=…) - removed:
function say(m, *fargs, **fkwargs) - removed:
function uuid() - removed:
method cached_property.deleter(fdel) - removed:
method cached_property.setter(fset) - added:
export EqualityDict - added:
export cached_property - added:
export emergency_dump_state - added:
export fileno - added:
export fxrange - added:
export fxrangemax - added:
export maybe_fileno - added:
export maybe_list - added:
export nested - added:
export register_after_fork - added:
export reprcall - added:
export retry_over_time - added:
export symbol_by_name - added:
export uuid
- added:
class EqualityDict(dict) - added:
class HashedSeq(list) - added:
constructor HashedSeq(*seq) - added:
function eqhash(o)
- removed:
function get_errno(exc) - removed:
function timedelta_seconds(delta) - removed:
variable HAVE_TIMEDELTA_TOTAL_SECONDS - added:
function NamedTuple(name, fields) - added:
function coro(gen) - added:
function detect_environment() - added:
function entrypoints(namespace) - added:
function fileno(f) - added:
function maybe_fileno(f) - added:
function nested(*managers) - added:
variable FILENO_ERRORS - added:
variable register_after_fork
- added:
function emergency_dump_state(state, open_file=…, dump=…, stderr=…)
- removed:
variable is_py3k
- changed:
function is_list(l, scalars=…, iters=…) → function is_list(obj, scalars=…, iters=…) - changed:
function maybe_list(l, scalars=…) → function maybe_list(obj, scalars=…) - added:
class LRUCache(UserDict) - added:
constructor LRUCache(limit=…) - added:
field LRUCache.items - added:
field LRUCache.iteritems - added:
field LRUCache.iterkeys - added:
field LRUCache.itervalues - added:
field LRUCache.keys - added:
field LRUCache.values - added:
function dictfilter(d=…, **kw) - added:
function memoize(maxsize=…, keyfun=…, Cache=…) - added:
method LRUCache.incr(key, delta=…) - added:
method LRUCache.items() - added:
method LRUCache.keys() - added:
method LRUCache.popitem(last=…) - added:
method LRUCache.update(*args, **kwargs) - added:
method LRUCache.values()
- added:
function symbol_by_name(name, aliases=…, imp=…, package=…, sep=…, default=…, **kwargs)
- added:
class DjangoPromise(object) - added:
class JSONEncoder(_encoder_cls) - added:
function dumps(s, _dumps=…, cls=…, default_kwargs=…, **kwargs) - added:
function loads(s, _loads=…, decode_bytes=…) - added:
method JSONEncoder.default(o, dates=…, times=…, textual=…, isinstance=…, datetime=…, text_t=…)
- added:
method TokenBucket.add(item) - added:
method TokenBucket.clear_pending() - added:
method TokenBucket.pop()
- added:
class cached_property(object) - added:
constructor cached_property(fget=…, fset=…, fdel=…, doc=…) - added:
method cached_property.deleter(fdel) - added:
method cached_property.setter(fset)
- added:
class FairCycle(object) - added:
class priority_cycle(round_robin_cycle) - added:
class round_robin_cycle(object) - added:
class sorted_cycle(priority_cycle) - added:
constructor FairCycle(fun, resources, predicate=…) - added:
constructor round_robin_cycle(it=…) - added:
method FairCycle.close() - added:
method FairCycle.get(callback, **kwargs) - added:
method priority_cycle.rotate(last_used) - added:
method round_robin_cycle.consume(n) - added:
method round_robin_cycle.rotate(last_used) - added:
method round_robin_cycle.update(it) - added:
method sorted_cycle.consume(n)
- added:
function escape_regex(p, white=…)
- added:
function maybe_s_to_ms(v)
- added:
function parse_ssl_cert_reqs(query_value) - added:
function url_to_parts(url) - added:
variable logger - added:
variable ssl_available - added:
variable urlparts
- added:
function uuid(_uuid=…)