Upgrading amqp 1 to 2
Unknown1.4.9 → 2.6.1
Fetching 23 releases from GitHub…0 / 23
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.
Requires Python >=2.7, !=3.0.*, !=3.1.*, !=3.2.*, !=3.3.*, !=3.4.* from 2.5.1 (none stated before).
Adds vine <5.0.0a1,>=1.1.3.
Installs 1 package in all (was 0).
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
variable VERSION
- changed:
method AbstractChannel.dispatch_method(method_sig, args, content) → method AbstractChannel.dispatch_method(method_sig, payload, content) - changed:
method AbstractChannel.wait(allowed_methods=…, timeout=…) → method AbstractChannel.wait(method, callback=…, timeout=…, returns_tuple=…) - added:
method AbstractChannel.send_method(sig, format=…, args=…, content=…, wait=…, callback=…, returns_tuple=…)
- added:
field Message.CLASS_ID - added:
property Message.delivery_tag - added:
property Message.headers
- changed:
constructor Channel(connection, channel_id=…, auto_decode=…) → constructor Channel(connection, channel_id=…, auto_decode=…, on_open=…) - changed:
method Channel.basic_ack(delivery_tag, multiple=…) → method Channel.basic_ack(delivery_tag, multiple=…, argsig=…) - changed:
method Channel.basic_cancel(consumer_tag, nowait=…) → method Channel.basic_cancel(consumer_tag, nowait=…, argsig=…) - changed:
method Channel.basic_consume(queue=…, consumer_tag=…, no_local=…, no_ack=…, exclusive=…, nowait=…, callback=…, arguments=…, on_cancel=…) → method Channel.basic_consume(queue=…, consumer_tag=…, no_local=…, no_ack=…, exclusive=…, nowait=…, callback=…, arguments=…, on_cancel=…, argsig=…) - changed:
method Channel.basic_get(queue=…, no_ack=…) → method Channel.basic_get(queue=…, no_ack=…, argsig=…) - changed:
method Channel.basic_qos(prefetch_size, prefetch_count, a_global) → method Channel.basic_qos(prefetch_size, prefetch_count, a_global, argsig=…) - changed:
method Channel.basic_reject(delivery_tag, requeue) → method Channel.basic_reject(delivery_tag, requeue, argsig=…) - changed:
method Channel.close(reply_code=…, reply_text=…, method_sig=…) → method Channel.close(reply_code=…, reply_text=…, method_sig=…, argsig=…) - changed:
method Channel.exchange_bind(destination, source=…, routing_key=…, nowait=…, arguments=…) → method Channel.exchange_bind(destination, source=…, routing_key=…, nowait=…, arguments=…, argsig=…) - changed:
method Channel.exchange_declare(exchange, type, passive=…, durable=…, auto_delete=…, nowait=…, arguments=…) → method Channel.exchange_declare(exchange, type, passive=…, durable=…, auto_delete=…, nowait=…, arguments=…, argsig=…) - changed:
method Channel.exchange_delete(exchange, if_unused=…, nowait=…) → method Channel.exchange_delete(exchange, if_unused=…, nowait=…, argsig=…) - changed:
method Channel.exchange_unbind(destination, source=…, routing_key=…, nowait=…, arguments=…) → method Channel.exchange_unbind(destination, source=…, routing_key=…, nowait=…, arguments=…, argsig=…) - changed:
method Channel.queue_bind(queue, exchange=…, routing_key=…, nowait=…, arguments=…) → method Channel.queue_bind(queue, exchange=…, routing_key=…, nowait=…, arguments=…, argsig=…) - changed:
method Channel.queue_declare(queue=…, passive=…, durable=…, exclusive=…, auto_delete=…, nowait=…, arguments=…) → method Channel.queue_declare(queue=…, passive=…, durable=…, exclusive=…, auto_delete=…, nowait=…, arguments=…, argsig=…) - changed:
method Channel.queue_delete(queue=…, if_unused=…, if_empty=…, nowait=…) → method Channel.queue_delete(queue=…, if_unused=…, if_empty=…, nowait=…, argsig=…) - changed:
method Channel.queue_purge(queue=…, nowait=…) → method Channel.queue_purge(queue=…, nowait=…, argsig=…) - changed:
method Channel.queue_unbind(queue, exchange, routing_key=…, nowait=…, arguments=…) → method Channel.queue_unbind(queue, exchange, routing_key=…, nowait=…, arguments=…, argsig=…) - added:
method Channel.collect() - added:
method Channel.open() - added:
method Channel.then(on_success, on_error=…)
- removed:
method Connection.read_timeout(timeout=…) - changed:
constructor Connection(host=…, userid=…, password=…, login_method=…, login_response=…, virtual_host=…, locale=…, client_properties=…, ssl=…, connect_timeout=…, channel_max=…, frame_max=…, heartbeat=…, on_blocked=…, on_unblocked=…, confirm_publish=…, **kwargs) → constructor Connection(host=…, userid=…, password=…, login_method=…, login_response=…, authentication=…, virtual_host=…, locale=…, client_properties=…, ssl=…, connect_timeout=…, channel_max=…, frame_max=…, heartbeat=…, on_open=…, on_blocked=…, on_unblocked=…, confirm_publish=…, on_tune_ok=…, read_timeout=…, write_timeout=…, socket_settings=…, frame_handler=…, frame_writer=…, **kwargs) - changed:
method Connection.Transport(host, connect_timeout, ssl=…) → method Connection.Transport(host, connect_timeout, ssl=…, read_timeout=…, write_timeout=…, socket_settings=…, **kwargs) - changed:
method Connection.channel(channel_id=…) → method Connection.channel(channel_id=…, callback=…) - changed:
method Connection.close(reply_code=…, reply_text=…, method_sig=…) → method Connection.close(reply_code=…, reply_text=…, method_sig=…, argsig=…) - added:
field Connection.bytes_recv - added:
field Connection.bytes_sent - added:
field Connection.library_properties - added:
field Connection.negotiate_capabilities - added:
method Connection.blocking_read(timeout=…) - added:
method Connection.collect() - added:
method Connection.connect(callback=…) - added:
method Connection.on_inbound_method(channel_id, method_sig, payload, content) - added:
method Connection.then(on_success, on_error=…) - added:
property Connection.frame_writer - added:
property Connection.on_inbound_frame - added:
property Connection.transport
- removed:
class NotConfirmed(RecoverableConnectionError) - added:
class AMQPDeprecationWarning(UserWarning) - added:
class MessageNacked(Exception)
- 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 clock_gettime - removed:
variable ctypes - removed:
variable exec_ - removed:
variable int_types - removed:
variable libSystem - removed:
variable librt - removed:
variable long_t - removed:
variable mach_absolute_time - removed:
variable map - 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:
class MethodReader(object) - removed:
constructor MethodReader(source) - removed:
method MethodReader.read_method() - added:
function frame_handler(connection, callback, unpack_from=…, content_methods=…) - added:
function frame_writer(connection, transport, pack=…, pack_into=…, range=…, len=…, bytes=…, str_to_bytes=…, text_t=…)
- added:
export SOL_TCP - added:
variable KNOWN_TCP_OPTS - added:
variable LINUX_VERSION - added:
variable pack - added:
variable pack_into - added:
variable unpack - added:
variable unpack_from
- added:
class AMQPLAIN(SASL) - added:
class EXTERNAL(SASL) - added:
class PLAIN(SASL) - added:
class RAW(SASL) - added:
class SASL(object) - added:
constructor AMQPLAIN(username, password) - added:
constructor PLAIN(username, password) - added:
constructor RAW(mechanism, response) - added:
field AMQPLAIN.mechanism - added:
field EXTERNAL.mechanism - added:
field PLAIN.mechanism - added:
field RAW.mechanism - added:
method AMQPLAIN.start(connection) - added:
method EXTERNAL.start(connection) - added:
method PLAIN.start(connection) - added:
method RAW.start(connection) - added:
method SASL.start(connection) - added:
property SASL.mechanism - added:
variable GSSAPI
- removed:
class AMQPReader(object) - removed:
class AMQPWriter(object) - removed:
constructor AMQPReader(source) - removed:
constructor AMQPWriter(dest=…) - removed:
function byte(n) - removed:
method AMQPReader.close() - removed:
method AMQPReader.read(n) - removed:
method AMQPReader.read_array() - removed:
method AMQPReader.read_bit() - removed:
method AMQPReader.read_float() - removed:
method AMQPReader.read_item() - removed:
method AMQPReader.read_long() - removed:
method AMQPReader.read_longlong() - removed:
method AMQPReader.read_longstr() - removed:
method AMQPReader.read_octet() - removed:
method AMQPReader.read_short() - removed:
method AMQPReader.read_shortstr() - removed:
method AMQPReader.read_table() - removed:
method AMQPReader.read_timestamp() - removed:
method AMQPWriter.close() - removed:
method AMQPWriter.flush() - removed:
method AMQPWriter.getvalue() - removed:
method AMQPWriter.write(s) - removed:
method AMQPWriter.write_array(a) - removed:
method AMQPWriter.write_bit(b) - removed:
method AMQPWriter.write_item(v, k=…) - removed:
method AMQPWriter.write_long(n) - removed:
method AMQPWriter.write_longlong(n) - removed:
method AMQPWriter.write_longstr(s) - removed:
method AMQPWriter.write_octet(n) - removed:
method AMQPWriter.write_short(n) - removed:
method AMQPWriter.write_shortstr(s) - removed:
method AMQPWriter.write_table(d) - removed:
method AMQPWriter.write_timestamp(v) - removed:
variable IS_PY3K - removed:
variable byte - changed:
constructor GenericContent(**props) → constructor GenericContent(frame_method=…, frame_args=…, **props) - added:
field GenericContent.CLASS_ID - added:
function decode_properties_basic(buf, offset) - added:
function dumps(format, values) - added:
function loads(format, buf, offset) - added:
method GenericContent.inbound_body(buf) - added:
method GenericContent.inbound_header(buf, offset=…) - added:
variable ILLEGAL_TABLE_TYPE_WITH_VALUE - added:
variable PROPERTY_CLASSES - added:
variable ftype_t
- added:
class Basic - added:
class Channel - added:
class Confirm - added:
class Connection - added:
class Exchange - added:
class Queue - added:
class Tx - added:
field Basic.Ack - added:
field Basic.CLASS_ID - added:
field Basic.Cancel - added:
field Basic.CancelOk - added:
field Basic.Consume - added:
field Basic.ConsumeOk - added:
field Basic.Deliver - added:
field Basic.Get - added:
field Basic.GetEmpty - added:
field Basic.GetOk - added:
field Basic.Nack - added:
field Basic.Publish - added:
field Basic.Qos - added:
field Basic.QosOk - added:
field Basic.Recover - added:
field Basic.RecoverAsync - added:
field Basic.RecoverOk - added:
field Basic.Reject - added:
field Basic.Return - added:
field Channel.CLASS_ID - added:
field Channel.Close - added:
field Channel.CloseOk - added:
field Channel.Flow - added:
field Channel.FlowOk - added:
field Channel.Open - added:
field Channel.OpenOk - added:
field Confirm.CLASS_ID - added:
field Confirm.Select - added:
field Confirm.SelectOk - added:
field Connection.Blocked - added:
field Connection.CLASS_ID - added:
field Connection.Close - added:
field Connection.CloseOk - added:
field Connection.Open - added:
field Connection.OpenOk - added:
field Connection.Secure - added:
field Connection.SecureOk - added:
field Connection.Start - added:
field Connection.StartOk - added:
field Connection.Tune - added:
field Connection.TuneOk - added:
field Connection.Unblocked - added:
field Exchange.Bind - added:
field Exchange.BindOk - added:
field Exchange.CLASS_ID - added:
field Exchange.Declare - added:
field Exchange.DeclareOk - added:
field Exchange.Delete - added:
field Exchange.DeleteOk - added:
field Exchange.Unbind - added:
field Exchange.UnbindOk - added:
field Queue.Bind - added:
field Queue.BindOk - added:
field Queue.CLASS_ID - added:
field Queue.Declare - added:
field Queue.DeclareOk - added:
field Queue.Delete - added:
field Queue.DeleteOk - added:
field Queue.Purge - added:
field Queue.PurgeOk - added:
field Queue.Unbind - added:
field Queue.UnbindOk - added:
field Tx.CLASS_ID - added:
field Tx.Commit - added:
field Tx.CommitOk - added:
field Tx.Rollback - added:
field Tx.RollbackOk - added:
field Tx.Select - added:
field Tx.SelectOk - added:
function method(method_sig, args=…, content=…) - added:
variable method_t
- removed:
class SSLError(Exception) - removed:
function create_transport(host, connect_timeout, ssl=…) - changed:
constructor SSLTransport(host, connect_timeout, ssl) → constructor SSLTransport(host, connect_timeout=…, ssl=…, **kwargs) - added:
function Transport(host, connect_timeout=…, ssl=…, **kwargs) - added:
function to_host_port(host, default=…) - added:
variable DEFAULT_SOCKET_SETTINGS - added:
variable SIGNED_INT_MAX
- removed:
class promise(object) - removed:
constructor promise(fun, args=…, kwargs=…, on_success=…, on_error=…) - removed:
function noop() - removed:
method promise.set_error_state(exc) - removed:
method promise.then(callback=…, on_error=…) - removed:
method promise.throw(exc) - added:
class NullHandler(logging.Handler) - added:
function bytes_to_str(s) - added:
function coro(gen) - added:
function get_logger(logger) - added:
function str_to_bytes(s) - added:
method NullHandler.emit(record)