Examples of org.apache.http.nio.protocol.UriHttpAsyncRequestHandlerMapper.register()

Class org.apache.http.nio.protocol.UriHttpAsyncRequestHandlerMapper

Examples of org.apache.http.nio.protocol.UriHttpAsyncRequestHandlerMapper.register()

org.apache.http.nio.protocol.UriHttpAsyncRequestHandlerMapper.register()
Registers the given {@link HttpAsyncRequestHandler} as a handler for URIsmatching the given pattern. @param pattern the pattern to register the handler for. @param handler the handler.

    }


    @Test
    public void testBasicAuthenticationSuccess() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new AuthHandler()));


        final BasicSchemeFactory myBasicAuthSchemeFactory = new BasicSchemeFactory() {


            @Override
            public AuthScheme create(final HttpContext context) {

View Full Code Here

        return target;
    }


    private HttpHost start() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("/echo/*", new BasicAsyncRequestHandler(new EchoHandler()));
        registry.register("/random/*", new BasicAsyncRequestHandler(new RandomHandler()));
        return start(registry, null);
    }


    @Test

View Full Code Here

    }


    private HttpHost start() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("/echo/*", new BasicAsyncRequestHandler(new EchoHandler()));
        registry.register("/random/*", new BasicAsyncRequestHandler(new RandomHandler()));
        return start(registry, null);
    }


    @Test
    public void testSingleGet() throws Exception {

View Full Code Here

    }


    @Test
    public void testStatefulConnections() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new SimpleService()));


        final UserTokenHandler userTokenHandler = new UserTokenHandler() {


            public Object getUserToken(final HttpContext context) {
                final Integer id = (Integer) context.getAttribute("user");

View Full Code Here

        // We build a client with 2 max active // connections, and 2 max per route.
        this.connMgr.setMaxTotal(maxConn);
        this.connMgr.setDefaultMaxPerRoute(maxConn);


        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new SimpleService()));


        final HttpHost target = start(registry, null);


        // Bottom of the pool : a *keep alive* connection to Route 1.
        final HttpContext context1 = new BasicHttpContext();

View Full Code Here

    }


    @Test
    public void testBasicAuthenticationSuccess() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new AuthHandler()));


        final TestCredentialsProvider credsProvider = new TestCredentialsProvider(
                new UsernamePasswordCredentials("test", "test"));


        this.httpclient = HttpAsyncClients.custom()

View Full Code Here

        HttpAsyncRequestHandlerMapper handlerMapperCopy = this.handlerMapper;
        if (handlerMapperCopy == null) {
            final UriHttpAsyncRequestHandlerMapper reqistry = new UriHttpAsyncRequestHandlerMapper();
            if (handlerMap != null) {
                for (Map.Entry<String, HttpAsyncRequestHandler<?>> entry: handlerMap.entrySet()) {
                    reqistry.register(entry.getKey(), entry.getValue());
                }
            }
            handlerMapperCopy = reqistry;
        }

View Full Code Here

    }


    @Test
    public void testHttpGets() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new SimpleRequestHandler()));
        final HttpHost target = start(registry, null);


        this.client.setMaxPerRoute(3);
        this.client.setMaxTotal(3);

View Full Code Here

    }


    @Test
    public void testHttpHeads() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new SimpleRequestHandler()));
        final HttpHost target = start(registry, null);


        this.client.setMaxPerRoute(3);
        this.client.setMaxTotal(3);

View Full Code Here

    }


    @Test
    public void testHttpPostsWithContentLength() throws Exception {
        final UriHttpAsyncRequestHandlerMapper registry = new UriHttpAsyncRequestHandlerMapper();
        registry.register("*", new BasicAsyncRequestHandler(new SimpleRequestHandler()));
        final HttpHost target = start(registry, null);


        this.client.setMaxPerRoute(3);
        this.client.setMaxTotal(3);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.