def METHOD_NAME(router, source, group, local, rp, spt_setup):
    "Expect MSDP SA."
    logger.info("waiting MSDP SA on router {}".format(router))
    test_func = partial(
        topotest.router_json_cmp,
        tgen.gears[router],
        "show ip msdp sa json",
        {group: {source: {"local": local, "rp": rp, "sptSetup": spt_setup}}},
    )
    _, result = topotest.run_and_expect(test_func, None, count=30, wait=1)
    assertmsg = '"{}" MSDP SA failure'.format(router)
    assert result is None, assertmsg