bc4e675ea087e448a70ab89b8c7ffda320fdd571
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START====================================
3  * DCAEGEN2-SERVICES-SDK
4  * =========================================================
5  * Copyright (C) 2020 Nokia. All rights reserved.
6  * Copyright (C) 2022 AT&T Intellectual Property. All rights reserved.
7  * =========================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *       http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=====================================
20  */
21
22 package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api;
23
24
25 import static org.assertj.core.api.Assertions.assertThatCode;
26 import static org.assertj.core.api.Assertions.assertThat;
27
28 import java.net.URISyntaxException;
29 import java.nio.file.Paths;
30 import org.junit.jupiter.api.Test;
31 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.ImmutableCbsClientConfiguration;
32 import org.onap.dcaegen2.services.sdk.security.ssl.ImmutableTrustStoreKeys;
33 import org.onap.dcaegen2.services.sdk.security.ssl.Passwords;
34 import org.onap.dcaegen2.services.sdk.security.ssl.SecurityKeysStore;
35 import reactor.core.publisher.Mono;
36
37 class CbsClientFactoryTest {
38
39     @Test
40     void shouldAllowMultipleSubscriptions() throws URISyntaxException {
41         //given
42         ImmutableCbsClientConfiguration sampleConfiguration = ImmutableCbsClientConfiguration.builder()
43             .appName("dcae-component")
44             .build();
45
46         //when
47         Mono<CbsClient> cbsClient = CbsClientFactory.createCbsClient(sampleConfiguration);
48
49         //then
50         assertThatCode(() -> {
51             CbsClient client1 = cbsClient.block();
52             CbsClient client2 = cbsClient.block();
53             assertThat(client1).isNotNull();
54             assertThat(client2).isNotNull();
55         }).doesNotThrowAnyException();
56     }
57 }