300798022007f886f4dc7da718992b545a616e5a
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * DCAEGEN2-SERVICES-SDK
4  * ================================================================================
5  * Copyright (C) 2018-2019 NOKIA Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.service.producer;
22
23 import io.netty.handler.ssl.SslContext;
24 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.CloudHttpClient;
25 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapPublisherConfiguration;
26 import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.utlis.SecurityKeysUtil;
27 import org.onap.dcaegen2.services.sdk.security.ssl.SecurityKeys;
28 import org.onap.dcaegen2.services.sdk.security.ssl.SslFactory;
29
30 /**
31  *
32  * @deprecated Use new API {@link org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.api.DmaapClientFactory}
33  */
34 @Deprecated
35 public class DmaaPRestTemplateFactory {
36
37     private SslFactory sslFactory;
38
39     public DmaaPRestTemplateFactory() {
40         this(new SslFactory());
41     }
42
43     DmaaPRestTemplateFactory(SslFactory sslFactory) {
44         this.sslFactory = sslFactory;
45     }
46
47     /**
48      * Function for creating RestTemplate object.
49      *
50      * @param publisherConfiguration - DMaaP publisher configuration object
51      * @return RestTemplate with correct ssl configuration
52      */
53     public CloudHttpClient build(DmaapPublisherConfiguration publisherConfiguration){
54         SslContext sslContext = createSslContext(publisherConfiguration);
55         return new CloudHttpClient(sslContext);
56     }
57
58     private SslContext createSslContext(DmaapPublisherConfiguration consumerConfiguration) {
59         if (consumerConfiguration.enableDmaapCertAuth()) {
60             final SecurityKeys securityKeys = SecurityKeysUtil
61                     .fromDmappCustomConfig(consumerConfiguration);
62             return sslFactory.createSecureClientContext(securityKeys);
63         }
64         return sslFactory.createInsecureClientContext();
65     }
66 }