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);
}