@Test(expected = RpcException.class)

    public void testFail() throws Exception {

        URL url = URL.valueOf("test://test");

                               "com.alibaba.dubbo.rpc.file.TpsService");

        url = url.addParameter(Constants.TPS_LIMIT_RATE_KEY, 5);

        Invoker<TpsLimitFilterTest> invoker = new MyInvoker<TpsLimitFilterTest>(url);

        Invocation invocation = new MockInvocation();

        for (int i = 0; i < 10; i++) {

    public void testFail() throws Exception {

        URL url = URL.valueOf("test://test");

        url = url.addParameter(Constants.INTERFACE_KEY,

                               "com.alibaba.dubbo.rpc.file.TpsService");

        Invoker<TpsLimitFilterTest> invoker = new MyInvoker<TpsLimitFilterTest>(url);

        Invocation invocation = new MockInvocation();

        for (int i = 0; i < 10; i++) {

            try {

                filter.invoke(invoker, invocation);

        URL             errorPathUrl            = URL.valueOf("notsupport:/" + "xxx"+"?refer=" + URL.encode("interface="+service));

        RegistryDirectory registryDirectory = getRegistryDirectory(errorPathUrl);

        List<URL> serviceUrls = new ArrayList<URL>();

        URL Dubbo1URL = URL.valueOf("dubbo://127.0.0.1:9098?lazy=true");

        registryDirectory.notify(serviceUrls);

        Assert.assertEquals(true, registryDirectory.isAvailable());

        invocation = new RpcInvocation();

        // without ROUTER_KEY, the first router should not be created.

        serviceUrls.add(routerurl.addParameter(Constants.CATEGORY_KEY, Constants.ROUTERS_CATEGORY).addParameter(Constants.TYPE_KEY, "javascript").addParameter(Constants.ROUTER_KEY,

                                                                                                 "notsupported").addParameter(Constants.RULE_KEY,

                                                                                                                              "function test1(){}"));

                                                                                                  ScriptRouterFactory.NAME).addParameter(Constants.RULE_KEY,

                                                                                                                                         "function test1(){}"));

        registryDirectory.notify(serviceUrls);

        List<Router> routers = registryDirectory.getRouters();

        List routers = registryDirectory.getRouters();

        Assert.assertEquals(1 + 1, routers.size());

        serviceUrls.clear();

        registryDirectory.notify(serviceUrls);

        routers = registryDirectory.getRouters();

        Assert.assertEquals(0 + 1, routers.size());

    }

        }

       

        URL u = URL.valueOf(url);

        if(group != null) {

        }

       

        if(version != null) u.addParameter("version", version);

       

        List<URL> lookup = registryService.lookup(u);

        if(group != null) {

            u.addParameter("group", group);

        }

       

       

        List<URL> lookup = registryService.lookup(u);

       

        Map<String, Map<String, String>> serviceUrl = new HashMap<String, Map<String,String>>();

        Map<String, String> urls = new HashMap<String, String>();

        url = url.addParameters(serviceName2Map);

       

        boolean dynamic = isDynamic();

        if(!dynamic) {

        }

        boolean enabled = isEnabled();

        if(enabled != url.getParameter("enabled", true)) {

            if(enabled) {

                url = url.removeParameter("enabled");

            if(enabled) {

                url = url.removeParameter("enabled");

            }

            else {

            }

        }

       

        return url;

    }

        url = url.setProtocol("dubbo");

        assertTrue(InjvmProtocol.getInjvmProtocol().isInjvmRefer(url));

            .addParameter(Constants.VERSION_KEY, "*");

        assertTrue(InjvmProtocol.getInjvmProtocol().isInjvmRefer(url));

    }

}