Fix problem with message label not being set.
Now if you provide subject="<subject>" to the message, it should set the label.
@@ -54,7 +54,7 @@ class Message(object): # pylint: disable=too-many-public-methods,too-many-insta
_x_OPT_SCHEDULED_ENQUEUE_TIME = b'x-opt-scheduled-enqueue-time'
def __init__(self, body, encoding='UTF-8', **kwargs):
- self.properties = uamqp.message.MessageProperties(encoding=encoding)
+ self.properties = uamqp.message.MessageProperties(encoding=encoding, **kwargs)
self.header = uamqp.message.MessageHeader()
self.received_timestamp = None
self.auto_renew_error = None
