async def METHOD_NAME(app_ctx, stan_server):
    """Assert that the service can connect to the STAN Queue."""
    queue = QueueService(app_ctx)
    # sanity check
    assert not queue.is_connected
    # test
    await queue.connect()
    assert queue.is_connected
    await queue.connect()
    assert queue.is_connected
    await queue.close()
    assert queue.is_closed