Upgrading amqp 0.9 to 1
Unknown0.9.4 → 1.4.9
Fetching 30 releases from GitHub…0 / 30
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 ConsumerCancel - added:
export AMQPNotImplementedError - added:
export AccessRefused - added:
export ChannelNotOpen - added:
export ConnectionForced - added:
export ConsumerCancelled - added:
export ContentTooLarge - added:
export FrameError - added:
export FrameSyntaxError - added:
export InternalError - added:
export InvalidCommand - added:
export InvalidPath - added:
export IrrecoverableChannelError - added:
export IrrecoverableConnectionError - added:
export NoConsumers - added:
export NotAllowed - added:
export NotFound - added:
export PreconditionFailed - added:
export RecoverableChannelError - added:
export RecoverableConnectionError - added:
export ResourceError - added:
export ResourceLocked - added:
export UnexpectedFrame - added:
export error_for_code - added:
export promise - added:
variable VERSION
- changed:
method AbstractChannel.wait(allowed_methods=…) → method AbstractChannel.wait(allowed_methods=…, timeout=…)
- changed:
constructor Message(body=…, children=…, **properties) → constructor Message(body=…, children=…, channel=…, **properties)
- removed:
method Channel.basic_publish(msg, exchange=…, routing_key=…, mandatory=…, immediate=…) - added:
field Channel.basic_publish - added:
method Channel.basic_publish_confirm(*args, **kwargs)
- removed:
field Connection.missed_heartbeats - changed:
constructor Connection(host=…, userid=…, password=…, login_method=…, login_response=…, virtual_host=…, locale=…, client_properties=…, ssl=…, connect_timeout=…, channel_max=…, frame_max=…, heartbeat=…, **kwargs) → 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) - added:
field Connection.client_heartbeat - added:
field Connection.heartbeat - added:
field Connection.last_heartbeat_received - added:
field Connection.last_heartbeat_sent - added:
field Connection.recoverable_channel_errors - added:
field Connection.recoverable_connection_errors - added:
field Connection.server_heartbeat - added:
method Connection.Transport(host, connect_timeout, ssl=…) - added:
property Connection.connected
- changed:
constructor AMQPError(msg, reply_code=…, reply_text=…, method_sig=…, method_name=…) → constructor AMQPError(reply_text=…, method_sig=…, method_name=…, reply_code=…) - added:
class AMQPNotImplementedError(IrrecoverableConnectionError) - added:
class AccessRefused(IrrecoverableChannelError) - added:
class ChannelNotOpen(IrrecoverableConnectionError) - added:
class ConnectionForced(RecoverableConnectionError) - added:
class ConsumerCancelled(RecoverableConnectionError) - added:
class ContentTooLarge(RecoverableChannelError) - added:
class FrameError(IrrecoverableConnectionError) - added:
class FrameSyntaxError(IrrecoverableConnectionError) - added:
class InternalError(IrrecoverableConnectionError) - added:
class InvalidCommand(IrrecoverableConnectionError) - added:
class InvalidPath(IrrecoverableConnectionError) - added:
class IrrecoverableChannelError(ChannelError) - added:
class IrrecoverableConnectionError(ConnectionError) - added:
class NoConsumers(RecoverableChannelError) - added:
class NotAllowed(IrrecoverableConnectionError) - added:
class NotConfirmed(RecoverableConnectionError) - added:
class NotFound(IrrecoverableChannelError) - added:
class PreconditionFailed(IrrecoverableChannelError) - added:
class RecoverableChannelError(ChannelError) - added:
class RecoverableConnectionError(ConnectionError) - added:
class ResourceError(RecoverableConnectionError) - added:
class ResourceLocked(RecoverableChannelError) - added:
class UnexpectedFrame(IrrecoverableConnectionError) - added:
field AMQPError.code - added:
field AMQPNotImplementedError.code - added:
field AccessRefused.code - added:
field ChannelNotOpen.code - added:
field ConnectionForced.code - added:
field ContentTooLarge.code - added:
field FrameError.code - added:
field FrameSyntaxError.code - added:
field InternalError.code - added:
field InvalidCommand.code - added:
field InvalidPath.code - added:
field NoConsumers.code - added:
field NotAllowed.code - added:
field NotFound.code - added:
field PreconditionFailed.code - added:
field ResourceError.code - added:
field ResourceLocked.code - added:
field UnexpectedFrame.code - added:
property AMQPError.method
- added:
class WhateverIO(StringIO) - added:
class timespec(ctypes.Structure) - added:
function exec_(code, globs=…, locs=…) - added:
function items(d) - added:
function keys(d) - added:
function nextfun(it) - added:
function reraise(tp, value, tb=…) - added:
function values(d) - added:
function with_metaclass(Type, skip_attrs=…) - added:
method WhateverIO.write(data) - added:
variable BytesIO - added:
variable CLOCK_MONOTONIC - added:
variable CoreServices - added:
variable PY3 - added:
variable SYSTEM - added:
variable WhateverIO - added:
variable absolute_to_nanoseconds - added:
variable clock_gettime - added:
variable ctypes - added:
variable exec_ - added:
variable int_types - added:
variable libSystem - added:
variable librt - added:
variable long_t - added:
variable mach_absolute_time - added:
variable map - added:
variable monotonic - added:
variable open_fqdn - added:
variable range - added:
variable reload - added:
variable string - added:
variable string_t - added:
variable text_t
- added:
variable basic_return_t - added:
variable queue_declare_ok_t
- removed:
variable bytes - added:
method AMQPReader.read_array() - added:
method AMQPReader.read_float() - added:
method AMQPReader.read_item() - added:
method AMQPWriter.write_array(a) - added:
method AMQPWriter.write_item(v, k=…) - added:
variable ILLEGAL_TABLE_TYPE - added:
variable ILLEGAL_TABLE_TYPE_WITH_KEY
- added:
class SSLError(Exception) - added:
class SSLTransport(_AbstractTransport) - added:
class TCPTransport(_AbstractTransport) - added:
constructor SSLTransport(host, connect_timeout, ssl) - added:
function create_transport(host, connect_timeout, ssl=…) - added:
variable AMQP_PORT - added:
variable AMQP_PROTOCOL_HEADER - added:
variable EMPTY_BUFFER - added:
variable IPV6_LITERAL
- added:
class promise(object) - added:
constructor promise(fun, args=…, kwargs=…, on_success=…, on_error=…) - added:
function get_errno(exc) - added:
function noop() - added:
function set_cloexec(fd, cloexec) - added:
method promise.set_error_state(exc) - added:
method promise.then(callback=…, on_error=…) - added:
method promise.throw(exc) - added:
variable fcntl