diff options
Diffstat (limited to 'prh-dmaap-client/src')
3 files changed, 51 insertions, 3 deletions
diff --git a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/DMaaPReactiveWebClientTest.java b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/DMaaPReactiveWebClientTest.java new file mode 100644 index 00000000..fad18699 --- /dev/null +++ b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/DMaaPReactiveWebClientTest.java @@ -0,0 +1,49 @@ +/* + * ============LICENSE_START======================================================= + * PNF-REGISTRATION-HANDLER + * ================================================================================ + * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.dcaegen2.services.prh.service; + +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; +import org.springframework.web.reactive.function.client.WebClient; + +/** + * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 7/5/18 + */ +public class DMaaPReactiveWebClientTest { + + @Test + public void builder_shouldBuildDMaaPReactiveWebClient() { + //given + WebClient dMaaPReactiveWebClient; + String dMaaPContentType = "*/*"; + String dMaaPUserName = "DMaaP"; + String dMaaPUserPassword = "DMaaP"; + + //when + dMaaPReactiveWebClient = new DMaaPReactiveWebClient.WebClientBuilder() + .dmaapContentType(dMaaPContentType) + .dmaapUserName(dMaaPUserName) + .dmaapUserPassword(dMaaPUserPassword).build(); + + //then + Assertions.assertNotNull(dMaaPReactiveWebClient); + + } +}
\ No newline at end of file diff --git a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/config/DmaapConsumerConfigurationTest.java b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/config/DmaapConsumerConfigurationTest.java index dc8f7b6e..96939771 100644 --- a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/config/DmaapConsumerConfigurationTest.java +++ b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/config/DmaapConsumerConfigurationTest.java @@ -1,4 +1,4 @@ -/*- +/* * ============LICENSE_START======================================================= * PNF-REGISTRATION-HANDLER * ================================================================================ diff --git a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/producer/DMaaPProducerReactiveHttpClientTest.java b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/producer/DMaaPProducerReactiveHttpClientTest.java index c0b0c40b..f1fb70b0 100644 --- a/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/producer/DMaaPProducerReactiveHttpClientTest.java +++ b/prh-dmaap-client/src/test/java/org/onap/dcaegen2/services/prh/service/producer/DMaaPProducerReactiveHttpClientTest.java @@ -55,7 +55,6 @@ public class DMaaPProducerReactiveHttpClientTest { DmaapPublisherConfiguration.class); private static final Integer RESPONSE_SUCCESS = 200; private static ConsumerDmaapModel consumerDmaapModel = new ConsumerDmaapModelForUnitTest(); - private static Mono<Integer> expectedResult = Mono.empty(); private static WebClient webClient = mock(WebClient.class); private static RequestBodyUriSpec requestBodyUriSpec; private static ResponseSpec responseSpec; @@ -85,7 +84,7 @@ public class DMaaPProducerReactiveHttpClientTest { @Test public void getHttpResponse_Success() { //given - expectedResult = Mono.just(RESPONSE_SUCCESS); + Mono<Integer> expectedResult = Mono.just(RESPONSE_SUCCESS); //when mockWebClientDependantObject(); |