2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2019 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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
20 package org.openecomp.sdc.be.config;
23 * Contains DMAAP Client configuration parameters
25 public class DmaapConsumerConfiguration {
27 private boolean active;
29 private String consumerGroup;
30 private String consumerId;
31 private Integer timeoutMs;
32 private Integer limit;
33 private Integer pollingInterval;
35 private Double latitude;
36 private Double longitude;
37 private String version;
38 private String serviceName;
39 private String environment;
40 private String partner;
41 private String routeOffer;
42 private String protocol;
43 private String contenttype;
44 private Boolean dme2TraceOn;
45 private String aftEnvironment;
46 private Integer aftDme2ConnectionTimeoutMs;
47 private Integer aftDme2RoundtripTimeoutMs;
48 private Integer aftDme2ReadTimeoutMs;
49 private String dme2preferredRouterFilePath;
50 private Credential credential;
51 private Integer timeLimitForNotificationHandleMs;
52 private boolean aftDme2SslEnable;
53 private boolean aftDme2ClientIgnoreSslConfig;
54 private String aftDme2ClientKeystore;
55 private String aftDme2ClientKeystorePassword;
56 private String aftDme2ClientSslCertAlias;
58 public String getHosts() {
62 public void setHosts(String hosts) {
66 public String getConsumerGroup() {
70 public void setConsumerGroup(String consumerGroup) {
71 this.consumerGroup = consumerGroup;
74 public String getConsumerId() {
78 public void setConsumerId(String consumerId) {
79 this.consumerId = consumerId;
82 public Integer getTimeoutMs() {
86 public void setTimeoutMs(Integer timeoutMs) {
87 this.timeoutMs = timeoutMs;
90 public Integer getLimit() {
94 public void setLimit(Integer limit) {
98 public Integer getPollingInterval() {
99 return pollingInterval;
102 public void setPollingInterval(Integer pollingInterval) {
103 this.pollingInterval = pollingInterval;
106 public String getTopic() {
110 public void setTopic(String topic) {
114 public Double getLatitude() {
118 public void setLatitude(Double latitude) {
119 this.latitude = latitude;
122 public Double getLongitude() {
126 public void setLongitude(Double longitude) {
127 this.longitude = longitude;
130 public String getVersion() {
134 public void setVersion(String version) {
135 this.version = version;
138 public String getServiceName() {
142 public void setServiceName(String serviceName) {
143 this.serviceName = serviceName;
146 public String getEnvironment() {
150 public void setEnvironment(String environment) {
151 this.environment = environment;
154 public String getPartner() {
158 public void setPartner(String partner) {
159 this.partner = partner;
162 public String getRouteOffer() {
166 public void setRouteOffer(String routeOffer) {
167 this.routeOffer = routeOffer;
170 public String getProtocol() {
174 public void setProtocol(String protocol) {
175 this.protocol = protocol;
178 public String getContenttype() {
182 public void setContenttype(String contenttype) {
183 this.contenttype = contenttype;
186 public Boolean isDme2TraceOn() {
190 public Boolean getDme2TraceOn() {
194 public void setDme2TraceOn(Boolean dme2TraceOn) {
195 this.dme2TraceOn = dme2TraceOn;
198 public String getAftEnvironment() {
199 return aftEnvironment;
202 public void setAftEnvironment(String aftEnvironment) {
203 this.aftEnvironment = aftEnvironment;
206 public Integer getAftDme2ConnectionTimeoutMs() {
207 return aftDme2ConnectionTimeoutMs;
210 public void setAftDme2ConnectionTimeoutMs(Integer aftDme2ConnectionTimeoutMs) {
211 this.aftDme2ConnectionTimeoutMs = aftDme2ConnectionTimeoutMs;
214 public Integer getAftDme2RoundtripTimeoutMs() {
215 return aftDme2RoundtripTimeoutMs;
218 public void setAftDme2RoundtripTimeoutMs(Integer aftDme2RoundtripTimeoutMs) {
219 this.aftDme2RoundtripTimeoutMs = aftDme2RoundtripTimeoutMs;
222 public Integer getAftDme2ReadTimeoutMs() {
223 return aftDme2ReadTimeoutMs;
226 public void setAftDme2ReadTimeoutMs(Integer aftDme2ReadTimeoutMs) {
227 this.aftDme2ReadTimeoutMs = aftDme2ReadTimeoutMs;
230 public String getDme2preferredRouterFilePath() {
231 return dme2preferredRouterFilePath;
234 public void setDme2preferredRouterFilePath(String dme2preferredRouterFilePath) {
235 this.dme2preferredRouterFilePath = dme2preferredRouterFilePath;
238 public Credential getCredential() {
242 public void setCredential(Credential credential) {
243 this.credential = credential;
246 public boolean isActive() {
250 public void setActive(boolean isActive) {
251 this.active = isActive;
254 public Integer getTimeLimitForNotificationHandleMs() {
255 return timeLimitForNotificationHandleMs;
258 public void setTimeLimitForNotificationHandleMs(Integer timeLimitForNotificationHandleMs) {
259 this.timeLimitForNotificationHandleMs = timeLimitForNotificationHandleMs;
262 public boolean isAftDme2SslEnable() {
263 return aftDme2SslEnable;
266 public void setAftDme2SslEnable(boolean aftDme2SslEnable) {
267 this.aftDme2SslEnable = aftDme2SslEnable;
270 public boolean isAftDme2ClientIgnoreSslConfig() {
271 return aftDme2ClientIgnoreSslConfig;
274 public void setAftDme2ClientIgnoreSslConfig(boolean aftDme2ClientIgnoreSslConfig) {
275 this.aftDme2ClientIgnoreSslConfig = aftDme2ClientIgnoreSslConfig;
278 public String getAftDme2ClientKeystore() {
279 return aftDme2ClientKeystore;
282 public void setAftDme2ClientKeystore(String aftDme2ClientKeystore) {
283 this.aftDme2ClientKeystore = aftDme2ClientKeystore;
286 public String getAftDme2ClientKeystorePassword() {
287 return aftDme2ClientKeystorePassword;
290 public void setAftDme2ClientKeystorePassword(String aftDme2ClientKeystorePassword) {
291 this.aftDme2ClientKeystorePassword = aftDme2ClientKeystorePassword;
294 public String getAftDme2ClientSslCertAlias() {
295 return aftDme2ClientSslCertAlias;
298 public void setAftDme2ClientSslCertAlias(String aftDme2ClientSslCertAlias) {
299 this.aftDme2ClientSslCertAlias = aftDme2ClientSslCertAlias;
303 public String toString() {
304 return "DmaapConsumerConfiguration [active=" + active + ", hosts=" + hosts + ", consumerGroup=" + consumerGroup + ", consumerId=" + consumerId
305 + ", timeoutMs=" + timeoutMs + ", limit=" + limit + ", pollingInterval=" + pollingInterval + ", topic=" + topic + ", latitude=" + latitude
306 + ", longitude=" + longitude + ", version=" + version + ", serviceName=" + serviceName + ", environment=" + environment + ", partner="
307 + partner + ", routeOffer=" + routeOffer + ", protocol=" + protocol + ", contenttype=" + contenttype + ", dme2TraceOn=" + dme2TraceOn
308 + ", aftEnvironment=" + aftEnvironment + ", aftDme2ConnectionTimeoutMs=" + aftDme2ConnectionTimeoutMs + ", aftDme2RoundtripTimeoutMs="
309 + aftDme2RoundtripTimeoutMs + ", aftDme2ReadTimeoutMs=" + aftDme2ReadTimeoutMs + ", dme2preferredRouterFilePath="
310 + dme2preferredRouterFilePath + ", credential=" + credential + ", timeLimitForNotificationHandleMs=" + timeLimitForNotificationHandleMs
311 + ", aftDme2SslEnable=" + aftDme2SslEnable + ", aftDme2ClientIgnoreSslConfig=" + aftDme2ClientIgnoreSslConfig + ", aftDme2ClientKeystore="
312 + aftDme2ClientKeystore + ", aftDme2ClientKeystorePassword=" + aftDme2ClientKeystorePassword + ", aftDme2ClientSslCertAlias="
313 + aftDme2ClientSslCertAlias + "]";
317 * Contains Dmaap Client credential parameters: username and password
319 public static class Credential {
321 private String username;
322 private String password;
324 public String getUsername() {
328 public void setUsername(String username) {
329 this.username = username;
332 public String getPassword() {
336 public void setPassword(String password) {
337 this.password = password;
341 public String toString() {
342 return "Credential [username=" + username + ", password=" + password + "]";