AMQP 1.0 client library for Python
MIT License
Bot releases are hidden (Show)
Published by yunhaoling almost 4 years ago
MessageProperties.user_id
triggering segmentation fault when the underlying C bytes are NULL.MessageProperties.user_id
being limited to 8 bytes.ReceiveClient
and ReceiveClientAsync
receive messages during connection establishment.Published by yunhaoling about 4 years ago
Published by yunhaoling about 4 years ago
Message.footer
and Message.delivery_annotation
were not encoded into the outgoing payload.Published by yunhaoling about 4 years ago
shutdown_after_timeout
to ReceiveClient
and ReceiveClientAsync
which gives control over whether to shutdown receiver after timeout.Published by yunhaoling over 4 years ago
MessageReceiver.reset_link_credit
which is responsible for resetting current available link credit on the receiver link and send update to the sender.Published by yunhaoling over 4 years ago
Published by yunhaoling over 4 years ago
Published by yunhaoling over 4 years ago
Published by yunhaoling almost 5 years ago
Published by yunhaoling almost 5 years ago
Published by yunhaoling about 5 years ago
ReceiveClient(Async)
and MessageReceiver(Async)
as part of the AMQP protocol.Message
(azure-sdk-for-python issue #7336).work
to MessageReceiver
and work_async
to MessageReceiverAsync
responsible for updating link status.Published by yunhaoling about 5 years ago
Published by yunhaoling about 5 years ago
update_token()
in JWTTokenAuth
and JWTTokenAsync
(issue #80).Published by yunhaoling about 5 years ago
JWTTokenAuth
and JWTTokenAsync
to support OAuth.Published by annatisch almost 6 years ago
Support for Python 2.7
TimeoutError
is raised in Python 3.x, this will be replaced with a new ~uamqp.errors.ClientTimeout exception in Python 2.7.str
object will be treated as bytes
in Python 3 and a Python 2 unicode
object will be treated like a Python 3 str
.AMQP encoding of an integer type will now automatically failover into a Long type or a double type if the value is too large.
Improved support for promptly detecting invalid ATTACH handles and raising the appropriate error.
Added types for AMQPDescribed, AMQPInt and AMQPuInt for explicit handling of int and unsigned int encoding.
Added new error errors.AMQPClientShutdown
as a wrapper for KeyboardInterrupt
to better handle interrupt handling.
Added better handling of keyboard interrupts during C callbacks to better facilitate clean client shutdown.
Added additional handling of keyboard interrupt at the C level to clean up annoying warnings.
Added classmethod Message.decode_from_bytes
to create a message from AMQP wire-encoded data.
Added Message.encode_message
method to retrieve the AMQP wire-encoded byte representation of the current message.
Fixed behaviour of Message.get_message_encoded_size()
to return accurate size.
Added new optional callback
argument to client.mgmt_request
to allow for custom handling of different status codes.
Added new client methods auth_complete()
and client_ready()
to allow for more fine-tuned monitoring or the client opening stages.
Client message handler is now a public attribute client.message_handler
(SendClient._message_sender
and ReceiveClient._message_receiver
are now deprecated).
Added automatic encoding of datetime.datetime
objects into AMQP timestamp.
Better support for Source filters with optional descriptor
argument in Source.set_filter()
and new Source.get_filter()
method.
Fixed Session settings not being passed to CBS session.
Added support for a callback on receipt on a Link ATTACH frame. Can be supplied to a client through the on_attach
keyword argument.
Removed unsued message.SequenceBody class.
Exposed BatchMessage.size_offset property for batch size customization.
Published by annatisch about 6 years ago
In addition to the updates in RC1:
Support for Python 2.7:
AMQP encoding of an integer type will now automatically failover into a Long type or a double type if the value is too large.
Improved support for promptly detecting invalid ATTACH handles and raising the appropriate error.
Added types for AMQPInt and AMQPuInt for explicit handling of int and unsigned int encoding.
Added classmethod Message.decode_from_bytes
to create a message from AMQP wire-encoded data.
Added Message.encode_message
method to retrieve the AMQP wire-encoded byte representation of the current message.
Fixed behaviour of Message.get_message_encoded_size()
to return accurate size.
Added new optional callback
argument to client.mgmt_request
to allow for custom handling of different status codes.
Added new client methods auth_complete()
and client_ready()
to allow for more fine-tuned monitoring or the client opening stages.
Client message handler is now a public attribute client.message_handler
(SendClient._message_sender
and ReceiveClient._message_receiver
are now deprecated).
Added automatic encoding of datetime.datetime
objects into AMQP timestamp.
Published by annatisch about 6 years ago
Support for Python 2.7
TimeoutError
is raised in Python 3.x, this will be replaced with a new ClientTimeout
exception in Python 2.7.str
object will be treated as bytes
in Python 3 and a Python 2 unicode
object will be treated like a Python 3 str
.Added new error AMQPClientShutdown
as a wrapper for KeyboardInterrupt
to better handle interrupt handling.
Added better handling of keyboard interrupts during C callbacks to better facilitate clean client shutdown.
Added additional handling of keyboard interrupt at the C level to clean up annoying warnings.
Published by annatisch about 6 years ago
Published by annatisch about 6 years ago
Published by annatisch about 6 years ago
Bug fix release to address some reported issues:
uamqp.send_message
, which now returns a list of uamqp.constants.MessageState
to indicate the success of each message sent.