2 * Copyright 2017 ZTE Corporation.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.openo.holmes.common.config;
19 import com.fasterxml.jackson.annotation.JsonProperty;
20 import java.util.HashMap;
22 import javax.validation.constraints.NotNull;
24 public class MQConfig {
28 public String brokerIp = "localhost";
32 public int brokerPort = 5672;
36 public String brokerUsername;
39 public String brokerPassword;
42 public boolean autoDiscover = false;
45 public String mqServiceName = "mqService";
48 public String mqServiceVersion = "v1";
52 public long healthCheckMillisecondsToWait = 2000; // 2 seconds
55 public int shutdownWaitInSeconds = 20;
58 public int timeToLiveInSeconds = -1; // Default no TTL. Jackson does not support java.util.Optional yet.
61 public Map<String, String> extConsumerConfMap = new HashMap<>();
64 public Map<String, String> extProducerConfMap = new HashMap<>();
68 public String toString() {
69 return "MQConfig [brokerIp=" + brokerIp + ", brokerPort=" + brokerPort + ", brokerUsername="
70 + brokerUsername + ", brokerPassword=" + brokerPassword + ", autoDiscover="
71 + autoDiscover + ", mqServiceName=" + mqServiceName + ", mqServiceVersion="
72 + mqServiceVersion + ", healthCheckMillisecondsToWait=" + healthCheckMillisecondsToWait
73 + ", shutdownWaitInSeconds=" + shutdownWaitInSeconds + ", timeToLiveInSeconds="
74 + timeToLiveInSeconds + "]";