def get_amqp_message()

in azurefunctions-extensions-bindings-servicebus/azurefunctions/extensions/bindings/servicebus/utils.py [0:0]

• 4 lines of code
• 1 McCabe index (conditional complexity)

def get_amqp_message(message: bytes, index: int):
    """
    Get the amqp message from the model_binding_data content
    and create the message.
    """
    amqp_message = message[index + len(_X_OPT_LOCK_TOKEN):]
    decoded_message = uamqp.Message().decode_from_bytes(amqp_message)

    return decoded_message