async def METHOD_NAME(app_ctx, stan_server):
    """Assert that payment tokens can be retrieved and decoded from the Queue."""
    # SETUP
    msgs = []
    this_loop = asyncio.get_event_loop()
    future = asyncio.Future(loop=this_loop)
    queue = QueueService(app_ctx, this_loop)
    await queue.connect()
    async def cb(msg):
        nonlocal msgs
        nonlocal future
        msgs.append(msg)
        if len(msgs) == 5:
            future.set_result(True)
    await queue.stan.subscribe(subject=queue.subject,
                               queue='colin_queue',
                               durable_name='colin_queue',
                               cb=cb)
    # TEST - add some messages to the queue
    for i in range(0, 5):
        payload = {'colinFiling': {'id': 1234 + i, }}
        await queue.async_publish_json(payload=payload)
    try:
        await asyncio.wait_for(future, 2, loop=this_loop)
    except Exception as err:
        print(err)
    # await queue.close()
    # CHECK the colinFilings were retrieved from the queue
    assert len(msgs) == 5
    for i in range(0, 5):
        m = msgs[i]
        assert 'colinFiling' in m.data.decode('utf-8')
        assert 1234 + i == dpath.util.get(json.loads(m.data.decode('utf-8')),
                                          'colinFiling/id')