in uamqp/errors.py [0:0]
def __init__(self, condition=None, description=None, encoding='UTF-8', info=None):
self._encoding = encoding
self._info = info
if condition:
self.error_condition = condition.encode(encoding) if isinstance(condition, str) else condition
else:
self.error_condition = b"amqp:internal-error"
self.error_description = None
if description:
self.error_description = description.encode(encoding) if isinstance(description, str) \
else description
else:
self.error_description = b""
if info and not isinstance(info, dict):
raise TypeError("Disposition error info must be a dictionary.")
self.error_info = utils.data_factory(info, encoding=encoding) if info else None
super(MessageRejected, self).__init__()