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
12 * http://www.apache.org/licenses/LICENSE-2.0
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=====================================
22 package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api;
25 import static org.assertj.core.api.Assertions.assertThatCode;
26 import static org.assertj.core.api.Assertions.assertThat;
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;
37 class CbsClientFactoryTest {
40 void shouldAllowMultipleSubscriptions() throws URISyntaxException {
42 ImmutableCbsClientConfiguration sampleConfiguration = ImmutableCbsClientConfiguration.builder()
43 .appName("dcae-component")
47 Mono<CbsClient> cbsClient = CbsClientFactory.createCbsClient(sampleConfiguration);
50 assertThatCode(() -> {
51 CbsClient client1 = cbsClient.block();
52 CbsClient client2 = cbsClient.block();
53 assertThat(client1).isNotNull();
54 assertThat(client2).isNotNull();
55 }).doesNotThrowAnyException();