Containerization feature of SO
[so.git] / common / src / main / java / org / onap / so / client / dmaap / rest / DMaaPRestClient.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2017 AT&T 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.so.client.dmaap.rest;
22
23 import java.net.URL;
24 import java.util.Base64;
25 import java.util.Map;
26
27 import org.onap.so.client.RestClient;
28 import org.onap.so.utils.TargetEntity;
29
30 public class DMaaPRestClient extends RestClient {
31
32         private final String username;
33         private final String password;
34         public DMaaPRestClient(URL url, String contentType, String username, String password) {
35                 super(url, contentType);
36                 this.username = username;
37                 this.password = password;
38         }
39
40     @Override
41     public TargetEntity getTargetEntity(){
42         return TargetEntity.DMAAP;
43     }
44
45         @Override
46         protected void initializeHeaderMap(Map<String, String> headerMap) {
47                 headerMap.put("Authorization", "Basic " + Base64.getEncoder().encodeToString((username + ":" + password).getBytes()));
48         }
49
50 }