Package javax.servlet

Examples of javax.servlet.Filter


    public void testBasic() throws Exception
    {
        ServletContext servletContext = new MockServletContext();
        FilterConfig filterConfig = new MockFilterConfig(servletContext);

        Filter f = new HiveMindFilter();

        f.init(filterConfig);

        Registry r = (Registry) servletContext.getAttribute(HiveMindFilter.CONTEXT_KEY);

        assertNotNull(r);

        ThreadEventNotifier t =
            (ThreadEventNotifier) r.getService(
                HiveMind.THREAD_EVENT_NOTIFIER_SERVICE,
                ThreadEventNotifier.class);

        Listener l = new Listener();

        t.addThreadCleanupListener(l);

        HttpServletRequest request = new MockRequest();

        f.doFilter(request, new MockResponse(), new MockFilterChain());

        assertSame(r, HiveMindFilter.getRegistry(request));

        assertEquals(true, l.getCleanup());

        f.destroy();

        try
        {
            t.addThreadCleanupListener(null);
            unreachable();
View Full Code Here


        }
    }

    public void testExceptionInInit() throws Exception
    {
        Filter f = new HiveMindFilter();

        interceptLogging(HiveMindFilter.class.getName());

        f.init(null);

        // It's a NPE that gets thrown.

        assertLoggedMessage("null");

        f.doFilter(new MockRequest(), new MockResponse(), new MockFilterChain());

        f.destroy();
    }
View Full Code Here

        f.destroy();
    }

    public void testDestroyWithoutRepository()
    {
        Filter f = new HiveMindFilter();

        f.destroy();
    }
View Full Code Here

        f.destroy();
    }

    public void testFilterWithoutRepository() throws Exception
    {
        Filter f = new HiveMindFilter();

        interceptLogging(HiveMindFilter.class.getName());

        f.doFilter(new MockRequest(), new MockResponse(), new MockFilterChain());

        assertLoggedMessage("Unable to cleanup current thread");
    }
View Full Code Here

        Boolean bridgeEndpoint = getAndRemoveParameter(parameters, "bridgeEndpoint", Boolean.class);
        Boolean matchOnUriPrefix = getAndRemoveParameter(parameters, "matchOnUriPrefix", Boolean.class);
        Boolean enableJmx = getAndRemoveParameter(parameters, "enableJmx", Boolean.class);
        Boolean enableMultipartFilter = getAndRemoveParameter(parameters, "enableMultipartFilter",
                                                              Boolean.class, true);
        Filter multipartFilter = resolveAndRemoveReferenceParameter(parameters, "multipartFilterRef", Filter.class);
        List<Filter> filters = resolveAndRemoveReferenceListParameter(parameters, "filtersRef", Filter.class);
        Long continuationTimeout = getAndRemoveParameter(parameters, "continuationTimeout", Long.class);
        Boolean useContinuation = getAndRemoveParameter(parameters, "useContinuation", Boolean.class);
        String httpMethodRestrict = getAndRemoveParameter(parameters, "httpMethodRestrict", String.class);
        HeaderFilterStrategy headerFilterStrategy = resolveAndRemoveReferenceParameter(parameters, "headerFilterStrategy", HeaderFilterStrategy.class);
View Full Code Here

                                + camelContext.getProperties().get(TMP_DIR));
            }
            context.setAttribute("javax.servlet.context.tempdir", file);
        }
        // if a filter ref was provided, use it.
        Filter filter = ((JettyHttpEndpoint) endpoint).getMultipartFilter();
        if (filter == null) {
            // if no filter ref was provided, use the default filter
            filter = new MultiPartFilter();
        }
        filterHolder.setFilter(new CamelFilterWrapper(filter));
        String pathSpec = endpoint.getPath();
        if (pathSpec == null || "".equals(pathSpec)) {
            pathSpec = "/";
        }
        if (endpoint.isMatchOnUriPrefix()) {
            pathSpec = pathSpec.endsWith("/") ? pathSpec + "*" : pathSpec + "/*";
        }
        addFilter(context, filterHolder, pathSpec);
        LOG.debug("using multipart filter implementation " + filter.getClass().getName() + " for path " + pathSpec);
    }
View Full Code Here

        return config;
    }

    public void testExceptionInInit() throws Exception
    {
        Filter f = new FailingAutoloadingHiveMindFilterFixture();

        interceptLogging(AutoloadingHiveMindFilter.class.getName());

        f.init(null);

        assertLoggedMessage("Forced failure");

        MockControl requestControl = newControl(HttpServletRequest.class);
        HttpServletRequest request = (HttpServletRequest) requestControl.getMock();
        HttpServletResponse response = (HttpServletResponse) newMock(HttpServletResponse.class);
        FilterChain chain = (FilterChain) newMock(FilterChain.class);

        request.setAttribute(AutoloadingHiveMindFilter.REQUEST_KEY, null);

        chain.doFilter(request, response);

        request.getAttribute(AutoloadingHiveMindFilter.REBUILD_REQUEST_KEY);
        requestControl.setReturnValue(null);

        replayControls();

        f.doFilter(request, response, chain);

        verifyControls();

        f.destroy();
    }
View Full Code Here

        f.destroy();
    }

    public void testDestroyWithoutRepository()
    {
        Filter f = new AutoloadingHiveMindFilter();

        f.destroy();
    }
View Full Code Here

        f.destroy();
    }

    public void testFilterWithoutRepository() throws Exception
    {
        Filter f = new AutoloadingHiveMindFilter();

        interceptLogging(AutoloadingHiveMindFilter.class.getName());

        MockControl requestControl = newControl(HttpServletRequest.class);
        HttpServletRequest request = (HttpServletRequest) requestControl.getMock();
        HttpServletResponse response = (HttpServletResponse) newMock(HttpServletResponse.class);
        FilterChain chain = (FilterChain) newMock(FilterChain.class);

        request.setAttribute(AutoloadingHiveMindFilter.REQUEST_KEY, null);

        chain.doFilter(request, response);

        request.getAttribute(AutoloadingHiveMindFilter.REBUILD_REQUEST_KEY);
        requestControl.setReturnValue(null);

        replayControls();

        f.doFilter(request, response, chain);

        assertLoggedMessage("Unable to cleanup current thread");

        verifyControls();
    }
View Full Code Here

        Boolean bridgeEndpoint = getAndRemoveParameter(parameters, "bridgeEndpoint", Boolean.class);
        Boolean matchOnUriPrefix = getAndRemoveParameter(parameters, "matchOnUriPrefix", Boolean.class);
        Boolean enableJmx = getAndRemoveParameter(parameters, "enableJmx", Boolean.class);
        Boolean enableMultipartFilter = getAndRemoveParameter(parameters, "enableMultipartFilter",
                                                              Boolean.class, true);
        Filter multipartFilter = resolveAndRemoveReferenceParameter(parameters, "multipartFilterRef", Filter.class);
        List<Filter> filters = resolveAndRemoveReferenceListParameter(parameters, "filtersRef", Filter.class);
        Long continuationTimeout = getAndRemoveParameter(parameters, "continuationTimeout", Long.class);
        Boolean useContinuation = getAndRemoveParameter(parameters, "useContinuation", Boolean.class);
        String httpMethodRestrict = getAndRemoveParameter(parameters, "httpMethodRestrict", String.class);
        HeaderFilterStrategy headerFilterStrategy = resolveAndRemoveReferenceParameter(parameters, "headerFilterStrategy", HeaderFilterStrategy.class);
View Full Code Here

TOP

Related Classes of javax.servlet.Filter

Copyright © 2018 www.massapicom. All rights reserved.
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.