Java 类javax.ws.rs.core.Application 实例源码

项目：trellis 文件：LdpAdminResourceTest.java

@Override
public Application configure() {

    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new TestAuthenticationFilter("testUser", ""));
    config.register(new WebAcFilter(emptyList(), mockAccessControlService));
    config.register(new AgentAuthorizationFilter(mockAgentService, asList("testUser")));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin),
                asList("PATCH", "POST", "PUT"),
                asList("Link", "Content-Type", "Accept", "Accept-Datetime"),
                asList("Link", "Content-Type", "Pragma", "Memento-Datetime"), true, 100));
    return config;
}

项目：GitHub 文件：Issue1341.java

@Override
protected Application configure() {
    enable(TestProperties.LOG_TRAFFIC);
    enable(TestProperties.DUMP_ENTITY);

    ResourceConfig config = new ResourceConfig();

    FastJsonProvider fastJsonProvider = new FastJsonProvider();
    FastJsonConfig fastJsonConfig = new FastJsonConfig();
    fastJsonConfig.setSerializerFeatures(SerializerFeature.DisableCircularReferenceDetect, SerializerFeature.BrowserSecure);
    fastJsonProvider.setFastJsonConfig(fastJsonConfig);

    config.register(fastJsonProvider);

    config.packages("com.alibaba.json.bvt.issue_1300");
    return config;
}

项目：trellis 文件：LdpUnauthorizedResourceTest.java

@Override
public Application configure() {

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    // Junit runner doesn't seem to work very well with JerseyTest
    initMocks(this);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, "http://example.org/"));
    config.register(new TestAuthenticationFilter("testUser", "group"));
    config.register(new WebAcFilter(asList(BASIC_AUTH, DIGEST_AUTH), mockAccessControlService));
    config.register(new CrossOriginResourceSharingFilter(asList(origin),
                asList("PATCH", "POST", "PUT"),
                asList("Link", "Content-Type", "Accept", "Accept-Datetime"),
                emptyList(), false, 0));
    return config;
}

项目：trellis 文件：LdpResourceNoAgentTest.java

@Override
public Application configure() {

    // Junit runner doesn't seem to work very well with JerseyTest
    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin), asList("PATCH", "POST", "PUT"),
                    asList("Link", "Content-Type", "Accept-Datetime"),
                    asList("Link", "Content-Type", "Memento-Datetime"), true, 100));
    return config;
}

项目：trellis 文件：LdpUserResourceTest.java

@Override
public Application configure() {

    // Junit runner doesn't seem to work very well with JerseyTest
    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new TestAuthenticationFilter("testUser", "group"));
    config.register(new WebAcFilter(emptyList(), mockAccessControlService));
    config.register(new AgentAuthorizationFilter(mockAgentService, emptyList()));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin), asList("PATCH", "POST", "PUT"),
                    asList("Link", "Content-Type", "Accept-Datetime"),
                    asList("Link", "Content-Type", "Memento-Datetime"), true, 100));
    return config;
}

项目：trellis 文件：LdpResourceTest.java

@Override
public Application configure() {

    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new AgentAuthorizationFilter(mockAgentService, emptyList()));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin), asList("PATCH", "POST", "PUT"),
                    asList("Link", "Content-Type", "Accept-Datetime"),
                    asList("Link", "Content-Type", "Memento-Datetime"), true, 100));
    return config;
}

项目：micrometer 文件：MetricsRequestEventListenerTimedTest.java

@Override
protected Application configure() {
    registry = new SimpleMeterRegistry();
    longTaskRequestStartedLatch = new CountDownLatch(1);
    longTaskRequestReleaseLatch = new CountDownLatch(1);

    final MetricsApplicationEventListener listener = new MetricsApplicationEventListener(
        registry, new DefaultJerseyTagsProvider(), METRIC_NAME, false);

    final ResourceConfig config = new ResourceConfig();
    config.register(listener);
    config.register(
        new TimedResource(longTaskRequestStartedLatch, longTaskRequestReleaseLatch));
    config.register(TimedOnClassResource.class);

    return config;
}

项目：app-ms 文件：SwaggerHandler.java

/**
 * Convenience method to construct and register the routes to a Vert.x router
 * with a base Spring application context.
 *
 * @param router
 *            vert.x router
 * @param applicationClasses
 *            application classes
 * @return the handlers
 */
@SafeVarargs
public static SwaggerHandler[] multipleRegisterToRouter(final Router router,
    final Class<? extends Application>... applicationClasses) {

    final SwaggerHandler[] ret = new SwaggerHandler[applicationClasses.length];
    int i = 0;
    for (final Class<? extends Application> applicationClass : applicationClasses) {
        final SwaggerHandler requestHandler = new SwaggerHandler(applicationClass);
        router.route(requestHandler.baseUriRoute())
            .useNormalisedPath(true)
            .handler(requestHandler);
        ret[i++] = requestHandler;
    }
    return ret;

}

项目：com-liferay-apio-architect 文件：ApioApplicationRegistrar.java

@Activate
public void activate(BundleContext bundleContext) {
    Application application = bundleContext.getService(_serviceReference);

    Dictionary<String, Object> properties = new Hashtable<>();

    String[] propertyKeys = _serviceReference.getPropertyKeys();

    for (String key : propertyKeys) {
        Object value = _serviceReference.getProperty(key);

        properties.put(key, value);
    }

    properties.put("osgi.jaxrs.application.base", "/");
    properties.put("osgi.jaxrs.name", ".default");

    _serviceRegistration = bundleContext.registerService(
        Application.class, application, properties);
}

项目：rest-jersey-utils 文件：AbstractListingResourceTest.java

@Override
protected Application configure() {

    enable(TestProperties.LOG_TRAFFIC);
    enable(TestProperties.DUMP_ENTITY);

    MockitoAnnotations.initMocks(this);

    ResourceConfig rs = new ResourceConfig();
    rs.register(TestBinder.forAllMocksOf(this));
    rs.register(JacksonJaxbJsonProvider.class);
    rs.register(TestResource.class);
    rs.property(ServerProperties.BV_SEND_ERROR_IN_RESPONSE, Boolean.TRUE);
    LinkFactoryResourceConfig.configure(rs);
    linkMetaFactory = LinkMetaFactory.createInsecureFactoryForTest();
    return rs;
}

项目：parsec-libraries 文件：JerseyValidationTest.java

@Override
protected Application configure() {
    //enable(TestProperties.LOG_TRAFFIC);
    //enable(TestProperties.DUMP_ENTITY);
    //
    // TODO: load web.xml directly
    // .property(
    //        "contextConfigLocation",
    //        "classpath:**/my-web-test-context.xml"
    //
    return new ResourceConfig(MyResource.class)
            .register(ParsecMoxyProvider.class)
            .register(JaxbExceptionMapper.class)
            .property(JaxbExceptionMapper.PROP_JAXB_DEFAULT_ERROR_CODE, JAXB_ERROR_CODE)
            .property(JaxbExceptionMapper.PROP_JAXB_DEFAULT_ERROR_MSG, JAXB_ERROR_MSG)
            .register(ValidationConfigurationContextResolver.class)
            .register(ParsecValidationExceptionMapper.class)
            .property(ParsecValidationExceptionMapper.PROP_VALIDATION_DEFAULT_ERROR_CODE, VALIDATION_ERROR_CODE)
            .property(ParsecValidationExceptionMapper.PROP_VALIDATION_DEFAULT_ERROR_MSG, VALIDATION_ERROR_MSG)
            .property(ServerProperties.METAINF_SERVICES_LOOKUP_DISABLE, true)
            .register(new MoxyJsonConfig().setFormattedOutput(true)
                    .property(MarshallerProperties.BEAN_VALIDATION_MODE, BeanValidationMode.NONE).resolver());

}

项目：trellis 文件：LdpAdminResourceTest.java

@Override
public Application configure() {

    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new TestAuthenticationFilter("testUser", ""));
    config.register(new WebAcFilter(emptyList(), mockAccessControlService));
    config.register(new AgentAuthorizationFilter(mockAgentService, asList("testUser")));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin),
                asList("PATCH", "POST", "PUT"),
                asList("Link", "Content-Type", "Accept", "Accept-Datetime"),
                asList("Link", "Content-Type", "Pragma", "Memento-Datetime"), true, 100));
    return config;
}

项目：trellis 文件：LdpUnauthorizedResourceTest.java

@Override
public Application configure() {

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    // Junit runner doesn't seem to work very well with JerseyTest
    initMocks(this);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, "http://example.org/"));
    config.register(new TestAuthenticationFilter("testUser", "group"));
    config.register(new WebAcFilter(asList(BASIC_AUTH, DIGEST_AUTH), mockAccessControlService));
    config.register(new CrossOriginResourceSharingFilter(asList(origin),
                asList("PATCH", "POST", "PUT"),
                asList("Link", "Content-Type", "Accept", "Accept-Datetime"),
                emptyList(), false, 0));
    return config;
}

项目：trellis 文件：LdpResourceTest.java

@Override
public Application configure() {

    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new AgentAuthorizationFilter(mockAgentService, emptyList()));
    config.register(new MultipartUploader(mockResourceService, mockBinaryResolver, BASE_URL));
    config.register(new CacheControlFilter(86400));
    config.register(new CrossOriginResourceSharingFilter(asList(origin), asList("PATCH", "POST", "PUT"),
                    asList("Link", "Content-Type", "Accept-Datetime"),
                    asList("Link", "Content-Type", "Memento-Datetime"), true, 100));
    return config;
}

项目：aries-jax-rs-whiteboard 文件：AriesJaxRSServiceRuntime.java

private static FailedApplicationDTO buildFailedApplicationDTO(
    int reason, CachingServiceReference<Application> serviceReference) {

    FailedApplicationDTO failedApplicationDTO = new FailedApplicationDTO();

    Object nameProperty = serviceReference.getProperty(
        JaxRSWhiteboardConstants.JAX_RS_NAME);

    failedApplicationDTO.name = nameProperty == null ?
        generateApplicationName(serviceReference::getProperty) :
        nameProperty.toString();
    failedApplicationDTO.serviceId =
        (long)serviceReference.getProperty("service.id");

    failedApplicationDTO.failureReason = reason;

    return failedApplicationDTO;
}

项目：jrestless 文件：AbstractLambdaContextReferencingBinderIntTest.java

@Override
protected Application configure() {
    ResourceConfig application = new ResourceConfig();
    application.register(new AbstractLambdaContextReferencingBinder() {
        @Override
        protected void configure() {
            bindReferencingLambdaContextFactory();
        }
    });
    testService = mock(TestService.class);

    lambdaContextProvider = mock(LambdaContextProvider.class);

    Binder binder = new InstanceBinder.Builder()
            .addInstance(testService, TestService.class, Singleton.class)
            .addInstance(lambdaContextProvider, LambdaContextProvider.class, Singleton.class)
            .build();
    application.register(binder);

    application.register(TestResource.class);
    application.register(LambdaContextSetter.class);
    return application;
}

项目：jrestless 文件：CorsFilterIntTest.java

@Override
protected Application configure() {
    CorsFilter corsFilter = new CorsFilter.Builder()
            .allowMethod(HttpMethod.DELETE)
            .allowMethod(HttpMethod.OPTIONS)
            .allowHeader("ah0")
            .allowHeader("ah1")
            .allowOrigin(DEFAULT_ORIGIN)
            .allowOrigin("http://test.com")
            .exposeHeader("eh0")
            .exposeHeader("eh1")
            .build();
    ResourceConfig application = new ResourceConfig();
    application.register(corsFilter);
    application.register(TestResource.class);
    return application;
}

项目：aries-jax-rs-whiteboard 文件：Whiteboard.java

private OSGi<ServiceTuple<Application>> deployApplication(
    ServiceTuple<Application> tuple) {

    return
        just(this::createBus).flatMap(bus ->
        just(() -> {
            CachingServiceReference<Application> serviceReference =
                tuple.getCachingServiceReference();

            Map<String, Object> properties = getProperties(
                serviceReference);

            properties.computeIfAbsent(
                JAX_RS_NAME, (__) -> generateApplicationName(
                    serviceReference::getProperty));

            return properties;
        }).flatMap(properties ->
        deployRegistrator(bus, tuple, properties).then(
        registerCXFServletService(bus, properties)).then(
        just(tuple)
    )));
}

项目：rx-jersey 文件：RxJerseyTest.java

@Override
protected Application configure() {
    ResourceConfig resourceConfig = new ResourceConfig()
            .register(LocatorFeature.class)
            .register(JacksonFeature.class)
            .register(RxJerseyClientFeature.class)
            .register(ServerResource.class)
            .register(new AbstractBinder() {
                @Override
                protected void configure() {
                    bind(RxJerseyTest.this).to(JerseyTest.class);
                }
            });

    configure(resourceConfig);

    return resourceConfig;
}

项目：rx-jersey 文件：RxJerseyTest.java

@Override
protected Application configure() {
    ResourceConfig resourceConfig = new ResourceConfig()
            .register(LocatorFeature.class)
            .register(JacksonFeature.class)
            .register(RxJerseyClientFeature.class)
            .register(ServerResource.class)
            .register(new AbstractBinder() {
                @Override
                protected void configure() {
                    bind(RxJerseyTest.this).to(JerseyTest.class);
                }
            });

    configure(resourceConfig);

    return resourceConfig;
}

项目：GitHub 文件：TestIssue885.java

@Override
protected Application configure() {
    enable(TestProperties.LOG_TRAFFIC);
    enable(TestProperties.DUMP_ENTITY);

    ResourceConfig config = new ResourceConfig();
    //config.register(new FastJsonFeature()).register(FastJsonProvider.class);
    config.register(new FastJsonFeature()).register(new FastJsonProvider().setPretty(true));
    config.packages("com.alibaba.fastjson");
    return config;
}

项目：GitHub 文件：Issue1367_jaxrs.java

@Override
protected Application configure() {
    enable(TestProperties.LOG_TRAFFIC);
    enable(TestProperties.DUMP_ENTITY);

    ResourceConfig config = new ResourceConfig();

    config.register(FastJsonProvider.class);
    config.packages("com.alibaba.json.bvt.issue_1300");
    return config;
}

项目：GitHub 文件：Issue1392.java

@Override
protected Application configure() {
    enable(TestProperties.LOG_TRAFFIC);
    enable(TestProperties.DUMP_ENTITY);

    ResourceConfig config = new ResourceConfig();

    config.register(FastJsonResolver.class);

    config.register(FastJsonFeature.class);

    config.packages("com.alibaba.json.bvt.issue_1300");
    return config;
}

项目：trellis 文件：CORSResourceTest.java

@Override
public Application configure() {

    initMocks(this);

    final String baseUri = getBaseUri().toString();
    final String origin = baseUri.substring(0, baseUri.length() - 1);

    final ResourceConfig config = new ResourceConfig();
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, BASE_URL));
    config.register(new CrossOriginResourceSharingFilter(asList("*"),
                asList("PATCH", "POST", "PUT"), asList("Link", "Content-Type", "Accept", "Accept-Datetime"),
                emptyList(), false, 0));
    return config;
}

项目：trellis 文件：LdpForbiddenResourceTest.java

@Override
public Application configure() {

    // Junit runner doesn't seem to work very well with JerseyTest
    initMocks(this);

    BASE_URL = getBaseUri().toString();

    final ResourceConfig config = new ResourceConfig();
    config.register(new TestAuthenticationFilter("testUser", "group"));
    config.register(new AgentAuthorizationFilter(mockAgentService, emptyList()));
    config.register(new WebAcFilter(emptyList(), mockAccessControlService));
    config.register(new LdpResource(mockResourceService, ioService, mockBinaryService, null));
    return config;
}

项目：beadledom 文件：SwaggerApiResource.java

@Override
public Response apiDeclaration(
    @PathParam("route") String route,
    @Context Application app,
    @Context ServletConfig sc,
    @Context HttpHeaders headers,
    @Context UriInfo uriInfo) {
  Response original = super.apiDeclaration(route, app, sc, headers, uriInfo);

  if (original.getEntity() == null || !(original.getEntity() instanceof ApiListing)) {
    return original;
  }

  ApiListing listing = (ApiListing) original.getEntity();
  if (listing.basePath() != null) {
    return original;
  }

  return Response.fromResponse(original)
      .entity(
          new ApiListing(
              listing.apiVersion(),
              listing.swaggerVersion(),
              uriInfo.getBaseUri().toString().replaceAll("/\\z", ""),
              listing.resourcePath(),
              listing.produces(),
              listing.consumes(),
              listing.protocols(),
              listing.authorizations(),
              listing.apis(),
              listing.models(),
              listing.description(),
              listing.position()
          )).build();
}

项目：beadledom 文件：SwaggerGuiceJaxrsScanner.java

@Override
public scala.collection.immutable.List<Class<?>> classesFromContext(
    Application app, ServletConfig sc) {
  List<Class<?>> classes = Lists.newArrayList();
  addJaxrsClasses(injector, classes);
  return JavaConverters.asScalaBufferConverter(classes).asScala().toList();
}

项目：sdn-controller-nsc-plugin 文件：InspectionHookApisTest.java

@Override
protected Application configure() {
    baseTestConfiguration();

    //configure services
    this.context = new OsgiContext();

    SdnControllerApi sdnApi = Mockito.mock(SdnControllerApi.class);
    this.context.registerService(SdnControllerApi.class, sdnApi);

    SampleSdnRedirectionApi sdnRedirApi = Mockito.mock(SampleSdnRedirectionApi.class);
    this.context.registerService(SampleSdnRedirectionApi.class, sdnRedirApi);

    InspectionHookApis service = new InspectionHookApis();
    this.context.registerInjectActivateService(service);

    ResourceConfig application = getBaseResourceConfiguration().register(service);

    //configure responses
    this.expectedResponseList = new ArrayList<String>();
    this.expectedResponseList.add("HookId");

    Mockito.<SdnRedirectionApi> when(sdnApi.createRedirectionApi(any(), any())).thenReturn(sdnRedirApi);

    try {
        Mockito.<List<String>> when(sdnRedirApi.getInspectionHooksIds()).thenReturn(this.expectedResponseList);
        Mockito.<InspectionHookElement> when(sdnRedirApi.getInspectionHook(any()))
                .thenReturn(createInspectionHookEntity());
        Mockito.<String> when(sdnRedirApi.installInspectionHook(any(), any(), any(), any(), any(), any()))
        .thenReturn("HookId");
        Mockito.doNothing().when(sdnRedirApi).updateInspectionHook(any());
        Mockito.doNothing().when(sdnRedirApi).removeInspectionHook(any());
        super.callRealMethods(sdnRedirApi);
    } catch (Exception ex) {
        Assert.fail(ex.getClass() + " : " + ex.getMessage());
    }

    return application;
}

项目：sdn-controller-nsc-plugin 文件：InspectionPortApisTest.java

@Override
protected Application configure() {
    baseTestConfiguration();

    //configure services
    this.context = new OsgiContext();

    SdnControllerApi sdnApi = Mockito.mock(SdnControllerApi.class);
    this.context.registerService(SdnControllerApi.class, sdnApi);

    SampleSdnRedirectionApi sdnRedirApi = Mockito.mock(SampleSdnRedirectionApi.class);
    this.context.registerService(SampleSdnRedirectionApi.class, sdnRedirApi);

    InspectionPortApis service = new InspectionPortApis();
    this.context.registerInjectActivateService(service);

    ResourceConfig application = getBaseResourceConfiguration().register(service);

    //configure responses
    this.expectedResponseList = new ArrayList<String>();
    this.expectedResponseList.add("InspPortId");

    Mockito.<SdnRedirectionApi> when(sdnApi.createRedirectionApi(any(), any()))
    .thenReturn(sdnRedirApi);

    try {
        Mockito.<List<String>> when(sdnRedirApi.getInspectionPortsIds()).thenReturn(this.expectedResponseList);
        Mockito.<InspectionPortElement> when(sdnRedirApi.getInspectionPort(any()))
                .thenReturn(createInspectionPortEntity());
        Mockito.<Element> when(sdnRedirApi.registerInspectionPort(any())).thenReturn(createInspectionPortEntity());
        Mockito.<Element> when(sdnRedirApi.updateInspectionPort(any())).thenReturn(createInspectionPortEntity());
        Mockito.doNothing().when(sdnRedirApi).removeInspectionPort(any());
        super.callRealMethods(sdnRedirApi);
    }
    catch (Exception ex) {
        Assert.fail(ex.getClass() + " : " + ex.getMessage());
    }

    return application;
}

项目：sdn-controller-nsc-plugin 文件：PortApisTest.java

@Override
protected Application configure() {
    baseTestConfiguration();

    //configure services
    this.context = new OsgiContext();

    SdnControllerApi sdnApi = Mockito.mock(SdnControllerApi.class);
    this.context.registerService(SdnControllerApi.class, sdnApi);

    SampleSdnRedirectionApi sdnRedirApi = Mockito.mock(SampleSdnRedirectionApi.class);
    this.context.registerService(SampleSdnRedirectionApi.class, sdnRedirApi);

    PortApis service = new PortApis();
    this.context.registerInjectActivateService(service);

    ResourceConfig application = getBaseResourceConfiguration().register(service);

    //configure responses
    this.expectedResponseList = new ArrayList<String>();
    this.expectedResponseList.add("ElementId");

    Mockito.<SdnRedirectionApi> when(sdnApi.createRedirectionApi(any(), any())).thenReturn(sdnRedirApi);

    try {
        Mockito.<List<String>> when(sdnRedirApi.getPortIds()).thenReturn(this.expectedResponseList);
        Mockito.<NetworkElement> when(sdnRedirApi.registerPort(any())).thenReturn(createPortEntity());
        Mockito.<NetworkElement> when(sdnRedirApi.getPort(any())).thenReturn(new PortEntity());
        Mockito.<NetworkElement> when(sdnRedirApi.updatePort(any())).thenReturn(createPortEntity());
        Mockito.doNothing().when(sdnRedirApi).removeInspectionPort(any());
        super.callRealMethods(sdnRedirApi);
    } catch (Exception ex) {
        Assert.fail(ex.getClass() + " : " + ex.getMessage());
    }

    return application;
}

项目：micrometer 文件：MetricsRequestEventListenerTest.java

@Override
protected Application configure() {
    registry = new SimpleMeterRegistry();

    final MetricsApplicationEventListener listener = new MetricsApplicationEventListener(
        registry, new DefaultJerseyTagsProvider(), METRIC_NAME, true);

    final ResourceConfig config = new ResourceConfig();
    config.register(listener);
    config.register(TestResource.class);

    return config;
}

项目：javamagazin-009-microkernel 文件：MainRest.java

public static void main(String[] args) {
  final Builder builder = Undertow
      .builder()
      .setDirectBuffers(true)
      .setServerOption(UndertowOptions.ENABLE_HTTP2 , true);

  final Application jaxRsActivator = new Application() {
    @Override
    public Set<Class<?>> getClasses() {
      final Set<Class<?>> classes = new HashSet<>();
      classes.add(ServiceREST.class);
      classes.add(LoginREST.class);
      return classes;
    }
  };

  final String realRestPort = System.getProperty(REST_PORT_PROPERTY , DEFAULT_REST_PORT + "");
  final String realRestHost = System.getProperty(REST_HOST_PROPERTY , MainRest.DEFAULT_HOST);

  System.setProperty(RESTEASY_PORT_PROPERTY , realRestPort);
  System.setProperty(RESTEASY_HOST_PROPERTY , realRestHost);

  builder.addHttpListener(Integer.parseInt(realRestPort) , realRestHost);
  jaxrsServer = new UndertowJaxrsServer().start(builder);
  final ResteasyDeployment deployment = new ResteasyDeployment();
  deployment.setApplication(jaxRsActivator);
  jaxrsServer.deploy(jaxrsServer.undertowDeployment(deployment)
                                .setDeploymentName("Rest")
                                .setContextPath(CONTEXT_PATH_REST)
                                .setClassLoader(MainRest.class.getClassLoader()));
}

项目：apm-client 文件：HelloMain.java

private String getPathSpec(Class<? extends Application> appClass) {
  ApplicationPath applicationPath = appClass.getAnnotation(ApplicationPath.class);
  StringBuilder pathSpec = new StringBuilder(applicationPath.value());
  if(pathSpec.length()==0 || pathSpec.charAt(pathSpec.length()-1)!='/') {
    pathSpec.append('/');
  }
  pathSpec.append('*');
  return pathSpec.toString();
}

项目：app-ms 文件：JaxRsRouter.java

/**
 * Register the routes.
 *
 * @param applicationClass
 *            application class to get the root
 * @param router
 *            router to apply the changes to
 * @param pathsProvider
 *            provides a list of Path classes
 * @param jaxRsHandler
 *            route handler
 */
public void register(final Class<? extends Application> applicationClass,
    final Router router,
    final PathsProvider pathsProvider,
    final Handler<RoutingContext> jaxRsHandler) {

    final String rootPath = Optional.ofNullable(applicationClass.getAnnotation(ApplicationPath.class)).map(ApplicationPath::value).orElse("");

    final SortedSet<JaxRsPath> paths = new TreeSet<>();
    pathsProvider.getPathAnnotatedClasses().forEach(clazz -> {
        final String classPath = Optional.ofNullable(clazz.getAnnotation(Path.class)).map(Path::value).orElse("");
        stream(clazz.getMethods()).filter(m -> m.getAnnotation(GET.class) != null
            || m.getAnnotation(POST.class) != null
            || m.getAnnotation(PUT.class) != null
            || m.getAnnotation(DELETE.class) != null).forEach(m -> {
                final String path = Optional.ofNullable(m.getAnnotation(Path.class)).map(Path::value).orElse("");
                final String[] consumes = Optional.ofNullable(m.getAnnotation(Consumes.class)).map(Consumes::value).orElse(new String[0]);
                final String[] produces = Optional.ofNullable(m.getAnnotation(Produces.class)).map(Produces::value).orElse(new String[0]);

                paths.add(new JaxRsPath(UriBuilder.fromPath(rootPath).path(classPath).path(path).toTemplate(), consumes, produces, getHttpMethod(m)));

            });
    });
    paths.forEach(p -> {
        p.apply(router, jaxRsHandler, failureHandler);
        LOG.debug("route={}", p);
    });

}

项目：app-ms 文件：SwaggerHandler.java

public SwaggerHandler(
    final Class<? extends Application> applicationClass) {

    final ApplicationPath annotation = applicationClass.getAnnotation(ApplicationPath.class);
    if (annotation != null) {
        baseUri = URI.create(annotation.value()).normalize();
    } else {
        baseUri = URI.create("/");
    }

    Application application;
    try {
        application = applicationClass.newInstance();
    } catch (InstantiationException
        | IllegalAccessException e) {
        throw new ExceptionInInitializerError(e);
    }

    swagger = new ClonableSwagger();
    final Reader swaggerReader = new Reader(swagger);
    final Set<Class<?>> resourceClasses = application.getClasses();
    if (resourceClasses.isEmpty()) {
        final String packageName = applicationClass.getPackage().getName();
        final Reflections reflections = new Reflections(packageName);
        reflections.getTypesAnnotatedWith(Api.class).forEach(swaggerReader::read);
        reflections.getTypesAnnotatedWith(SwaggerDefinition.class).forEach(swaggerReader::read);
    } else {
        swaggerReader.read(applicationClass);
        resourceClasses.forEach(swaggerReader::read);
    }

}

项目：app-ms 文件：Microservice.java

/**
 * Bootstrap the microservice application.
 *
 * @param applicationClass
 *            JAX-RS Application class
 * @param extraSources
 *            extra source classes.
 * @param args
 *            command line arguments
 */
public static void run(final Class<? extends Application> applicationClass,
    final Class<?>[] extraSources,
    final String... args) {

    if (!microserviceEngineIterator.hasNext()) {
        throw new LinkageError("No MicroserviceEngine was defined");
    }
    final MicroserviceEngine microserviceEngine = microserviceEngineIterator.next();
    if (microserviceEngineIterator.hasNext()) {
        throw new LinkageError(format("Multiple MicroserviceEngine was defined, %s, %s and possibly more", microserviceEngine, microserviceEngineIterator.next()));
    }
    if (Microservice.applicationClass != null) {
        throw new LinkageError("Another Application class has already been registered in this JVM.");
    }
    Microservice.applicationClass = applicationClass;

    final Object[] bootstrapObjects = microserviceEngine.bootstrap();
    final Object[] sources = new Object[extraSources.length + bootstrapObjects.length];

    System.arraycopy(extraSources, 0, sources, 0, extraSources.length);
    System.arraycopy(bootstrapObjects, 0, sources, extraSources.length, bootstrapObjects.length);

    final SpringApplication springApplication = new SpringApplication(sources);
    springApplication.setWebEnvironment(false);
    springApplication
        .setBannerMode(Mode.OFF);
    springApplication.run(args);
}

项目：osc-core 文件：AlarmApisTest.java

@Override
protected Application configure() {
    baseTestConfiguration();

    //configure services
    this.context = new OsgiContext();
    ApiUtil apiUtil = Mockito.mock(ApiUtil.class);
    this.context.registerService(apiUtil);
    AddAlarmServiceApi addAlarm = Mockito.mock(AddAlarmServiceApi.class);
    this.context.registerService(AddAlarmServiceApi.class, addAlarm);
    UpdateAlarmServiceApi updateAlarm = Mockito.mock(UpdateAlarmServiceApi.class);
    this.context.registerService(UpdateAlarmServiceApi.class, updateAlarm);
    DeleteAlarmServiceApi deleteAlarm = Mockito.mock(DeleteAlarmServiceApi.class);
    this.context.registerService(DeleteAlarmServiceApi.class, deleteAlarm);
    ListAlarmServiceApi listAlarm = Mockito.mock(ListAlarmServiceApi.class);
    this.context.registerService(ListAlarmServiceApi.class, listAlarm);

    GetDtoFromEntityServiceFactoryApi getDtoFactory = Mockito.mock(GetDtoFromEntityServiceFactoryApi.class);
    this.context.registerService(GetDtoFromEntityServiceFactoryApi.class, getDtoFactory);

    UserContextApi userContext = Mockito.mock(UserContextApi.class);
    this.context.registerService(UserContextApi.class, userContext);

    AlarmApis service = new AlarmApis();
    this.context.registerInjectActivateService(service);

    ResourceConfig application = getBaseResourceConfiguration()
            .register(service);

    //configure responses
    this.expectedResponseList = new ListResponse<AlarmDto>();
    this.expectedResponse = Response.status(Response.Status.ACCEPTED).build();
    Mockito.<ListResponse<?>>when(apiUtil.getListResponse(any(), any())).thenReturn(this.expectedResponseList);
    when(apiUtil.getResponseForBaseRequest(any(), any())).thenReturn(this.expectedResponse);

    return application;
}

项目：dropwizard-vavr 文件：LazyParamConverterProviderTest.java

@Override
protected Application configure() {
    forceSet(TestProperties.CONTAINER_PORT, "0");
    return DropwizardResourceConfig.forTesting(new MetricRegistry())
            .register(LazyParamFeature.class)
            .register(TestResource.class);
}

项目：dropwizard-vavr 文件：OptionParamConverterProviderTest.java

@Override
protected Application configure() {
    forceSet(TestProperties.CONTAINER_PORT, "0");
    return DropwizardResourceConfig.forTesting(new MetricRegistry())
            .register(OptionParamFeature.class)
            .register(TestResource.class);
}

项目：dropwizard-vavr 文件：ValueMessageBodyWriterTest.java

@Override
protected Application configure() {
    forceSet(TestProperties.CONTAINER_PORT, "0");
    return DropwizardResourceConfig.forTesting(new MetricRegistry())
            .register(ValueMessageBodyWriter.class)
            .register(EmptyValueExceptionMapper.class)
            .register(TestResource.class);
}