java类javax.ws.rs.ext.RuntimeDelegate的实例源码

/**
 * Starts Grizzly HTTP server exposing static content, JAX-RS resources
 * and web sockets defined in this application.
 *
 * @param webRootPath static content root path.
 * @return Grizzly HTTP server.
 */
public static HttpServer startServer(String webRootPath) 
{
    final HttpServer server = new HttpServer();
    final NetworkListener listener = new NetworkListener("grizzly", BASE_URI, PORT);

    server.addListener(listener);

    final ServerConfiguration config = server.getServerConfiguration();
    // add handler for serving static content
    config.addHttpHandler(new StaticContentHandler(webRootPath), APP_PATH);

    // add handler for serving JAX-RS resources
    config.addHttpHandler(  RuntimeDelegate
                            .getInstance()
                            .createEndpoint(new ResourceConfig().packages("it.unito.geosummly.api"),
                                            GrizzlyHttpContainer.class),
                                            API_PATH
                          );

    try {
        // Start the server.
        server.start();
    } catch (Exception ex) {
        throw new ProcessingException("Exception thrown when trying to start grizzly server", ex);
    }

    return server;
}

@Bean @DependsOn( "cxf" )
public Server jaxRsServer() {
    JAXRSServerFactoryBean factory = RuntimeDelegate.getInstance().createEndpoint( jaxRsApiApplication(), JAXRSServerFactoryBean.class );
    factory.setServiceBeans( Arrays.< Object >asList( peopleRestService() ) );
    factory.setAddress( "/" + factory.getAddress() );
    factory.setProviders( Arrays.< Object >asList( jsonProvider() ) );
    return factory.create();
}

@Bean @DependsOn( "cxf" )
public Server jaxRsServer() {
    JAXRSServerFactoryBean factory = RuntimeDelegate.getInstance().createEndpoint( jaxRsApiApplication(), JAXRSServerFactoryBean.class );
    factory.setServiceBeans( Arrays.< Object >asList( peopleRestService() ) );
    factory.setAddress( "/" + factory.getAddress() );
    factory.setProviders( Arrays.< Object >asList( jsonProvider() ) );
    return factory.create();
}

@BeforeClass
public static void startServer() throws IOException {
    mockServer = new FeaturedHttpServerBuilder().port(-1).observer(new RequestObserver() {
        @Override
        public void onRequest(final FullHttpRequest request) {
            if (request.getUri().endsWith("start/simple")) {
                final String actual = new String(request.content().array());
                assertEquals(actual, "{\"entries\":[{\"key\":\"a\",\"value\":\"b\"}]}");
            }
        }
    }).build().start();
    port = mockServer.getPort();
    RuntimeDelegate.setInstance(null); // reset
}

@Test
public void testCreateResponseBuilder() {
    final ResponseBuilder rb = RuntimeDelegate.getInstance().createResponseBuilder();
    assertNotNull(rb);
}

@Test
public void testCreateMediaTypeDelegate() {
    final HeaderDelegate<MediaType> d = RuntimeDelegate.getInstance().createHeaderDelegate(MediaType.class);
    assertNotNull(d);
    assertTrue(d instanceof MinijaxMediaTypeDelegate);
}

@Test
public void testCreateCookieDelegate() {
    final HeaderDelegate<Cookie> d = RuntimeDelegate.getInstance().createHeaderDelegate(Cookie.class);
    assertNotNull(d);
    assertTrue(d instanceof MinijaxCookieDelegate);
}

@Test
public void testCreateNewCookieDelegate() {
    final HeaderDelegate<NewCookie> d = RuntimeDelegate.getInstance().createHeaderDelegate(NewCookie.class);
    assertNotNull(d);
    assertTrue(d instanceof MinijaxNewCookieDelegate);
}