Package org.glassfish.jersey.server

Examples of org.glassfish.jersey.server.ContainerRequest


            Assert.assertFalse(allow.contains("HEAD"));
        }
    }

    private ContainerResponse testOptions(MediaType requestType, ApplicationHandler application, String path) throws InterruptedException, ExecutionException {
        final ContainerRequest request = RequestContextBuilder.from(path, "OPTIONS").accept(requestType)
                .build();
        final ContainerResponse response = application.apply(request).get();
        Assert.assertEquals(200, response.getStatus());
        final MediaType type = response.getMediaType();
        Assert.assertEquals(requestType, type);
View Full Code Here


            throws ExecutionException, InterruptedException {
        RequestContextBuilder requestContextBuilder = RequestContextBuilder.from("/", method);
        if (entity != null) {
            requestContextBuilder.entity(entity).type(mediaType);
        }
        ContainerRequest requestContext = requestContextBuilder.accept(accept).build();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        app.apply(requestContext, baos);
        assertEquals(expected, baos.toString());
    }
View Full Code Here

    }

    @Test
    public void testNoEntity() throws IOException {
        EncodingFilter filter = initializeAndGetFilter();
        ContainerRequest request = RequestContextBuilder.from("/resource", "GET").header(HttpHeaders.ACCEPT_ENCODING,
                "gzip").build();
        ContainerResponse response = new ContainerResponse(request, Response.ok().build());
        filter.filter(request, response);
        assertNull(response.getHeaders().getFirst(HttpHeaders.CONTENT_ENCODING));
        assertNull(response.getHeaders().getFirst(HttpHeaders.VARY));
View Full Code Here

        EncodingFilter filter = initializeAndGetFilter();
        RequestContextBuilder builder = RequestContextBuilder.from("/resource", "GET");
        for (String a : accepted) {
            builder.header(HttpHeaders.ACCEPT_ENCODING, a);
        }
        ContainerRequest request = builder.build();
        ContainerResponse response = new ContainerResponse(request, Response.ok("OK!").build());
        filter.filter(request, response);
        if (response.getStatus() != 200) {
            throw new WebApplicationException(Response.status(response.getStatus()).build());
        }
View Full Code Here

    }

    @Override
    protected Object doInvoke(MuleEvent event) throws Exception
    {
        ContainerRequest req = buildRequest(event);
        req.setSecurityContext(DEFAULT_SECURITY_CONTEXT);

        MuleMessage message = event.getMessage();
        req.setEntityStream(getInputStream(message));
        copyProperties(message, req);

        return execute(req, event);
    }
View Full Code Here

        {
            logger.debug("Base URI: " + baseUri);
            logger.debug("Complete URI: " + completeUri);
        }

        return new ContainerRequest(baseUri, completeUri, method, null, new MapPropertiesDelegate());
    }
View Full Code Here

        UriBuilder baseUriBuilder = UriBuilder.fromUri(uri)
                .replacePath(baseUri.getPath())
                .replaceQuery(null);

        // Create the jersey request
        final ContainerRequest jerseyRequest = new ContainerRequest(
                baseUriBuilder.build(),
                uri,
                vertxRequest.method().name(),
                new DefaultSecurityContext(isSecure),
                new MapPropertiesDelegate());
View Full Code Here

    @Test(dataProvider = "methods")
    public void testRequestUnmodifiedWithNoOverride(String method)
    {
        OverrideMethodFilter filter = new OverrideMethodFilter();

        ContainerRequest request = new ContainerRequest(
                URI.create("http://www.example.com/"),
                URI.create("http://www.example.com/"),
                method,
                new MockSecurityContext(),
                new MockPropertiesDelegate());

        filter.filter(request);
        assertEqualsIgnoreCase(request.getMethod(), method);
    }
View Full Code Here

    @Test
    public void testHeaderHasPrecedenceOverQueryParam()
    {
        OverrideMethodFilter filter = new OverrideMethodFilter();

        ContainerRequest request = new ContainerRequest(
                URI.create("http://www.example.com/"),
                URI.create("http://www.example.com/?_method=PUT"),
                "POST",
                new MockSecurityContext(),
                new MockPropertiesDelegate());
        request.header(OverrideMethodFilter.HEADER, "DELETE");

        filter.filter(request);
        assertEqualsIgnoreCase(request.getMethod(), "DELETE");

    }
View Full Code Here

    public static String testQueryParam(String requestMethod, String override)
    {
        OverrideMethodFilter filter = new OverrideMethodFilter();

        ContainerRequest request = new ContainerRequest(
                URI.create("http://www.example.com/"),
                URI.create(String.format("http://www.example.com/?_method=%s", override)),
                requestMethod,
                new MockSecurityContext(),
                new MockPropertiesDelegate());

        filter.filter(request);
        return request.getMethod();
    }
View Full Code Here

TOP

Related Classes of org.glassfish.jersey.server.ContainerRequest

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.