@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; }
@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; }
@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; }
@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; }
@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; }
@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; }
@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; }
/** * 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; }
@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); }
@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; }
@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()); }
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; }
@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; }
@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; }
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) ))); }
@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; }
@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; }
@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; }
@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; }
@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; }
@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; }
@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(); }
@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(); }
@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; }
@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; }
@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; }
@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; }
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())); }
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(); }
/** * 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); }); }
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); } }
/** * 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); }
@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; }
@Override protected Application configure() { forceSet(TestProperties.CONTAINER_PORT, "0"); return DropwizardResourceConfig.forTesting(new MetricRegistry()) .register(LazyParamFeature.class) .register(TestResource.class); }
@Override protected Application configure() { forceSet(TestProperties.CONTAINER_PORT, "0"); return DropwizardResourceConfig.forTesting(new MetricRegistry()) .register(OptionParamFeature.class) .register(TestResource.class); }
@Override protected Application configure() { forceSet(TestProperties.CONTAINER_PORT, "0"); return DropwizardResourceConfig.forTesting(new MetricRegistry()) .register(ValueMessageBodyWriter.class) .register(EmptyValueExceptionMapper.class) .register(TestResource.class); }