@then('the cu-handler receives the {received_message} message of the type {message_type} for Cu-Point {cu_point_name}')
@defer.oisInlineCallbacks()
def step_verify_order_impl(context, received_message, message_type, cu_point_name):
    helper = BehaveHelper()
    cu_point_type = helper.get_cu_point_type_by_name(context,
                                                     cu_point_name)

    helper.check_existence_of_message_with_type_in_reference_data(received_message,
                                                                  message_type,
                                                                  context.reference_data.verification_message_type_dict)

    yield context.test_app.verify_ois_to_cu_message(cu_point_name,
                                                    cu_point_type,
                                                    received_message,
                                                    context.reference_data)

    yield sleep(1)

@then('the consumer receives the {received_message} order_answer message of the type {message_type}')
@defer.oisInlineCallbacks()
def step_verify_order_answer_impl(context, received_message, message_type):
    context.cache = context.test_app.get_order_answer_cache()

    helper = BehaveHelper()
    helper.check_existence_of_message_with_type_in_reference_data(received_message,
                                                                  message_type,
                                                                  context.reference_data.verification_message_type_dict)

    context.reference_attribute_dict = context.reference_data.ois_vu_verification_dict.get(received_message)
    helper.check_existence_of_one_order_answer_in_cache(context)

    helper.verify_ois_to_vu_message(context)

    yield sleep(1)