2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017-2018 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=========================================================
21 package org.onap.policy.common.endpoints.event.comm.bus.internal;
23 import java.util.List;
25 import org.onap.policy.common.endpoints.event.comm.Topic;
26 import org.onap.policy.common.endpoints.event.comm.bus.UebTopicSource;
29 * This topic source implementation specializes in reading messages over an UEB Bus topic source and
30 * notifying its listeners
32 public class SingleThreadedUebTopicSource extends SingleThreadedBusTopicSource implements UebTopicSource {
36 * @param servers UEB servers
37 * @param topic UEB Topic to be monitored
38 * @param apiKey UEB API Key (optional)
39 * @param apiSecret UEB API Secret (optional)
40 * @param consumerGroup UEB Reader Consumer Group
41 * @param consumerInstance UEB Reader Instance
42 * @param fetchTimeout UEB fetch timeout
43 * @param fetchLimit UEB fetch limit
44 * @param useHttps does topicSource use HTTPS?
45 * @param allowSelfSignedCerts does topicSource allow self-signed certs?
47 * @throws IllegalArgumentException An invalid parameter passed in
51 public SingleThreadedUebTopicSource(List<String> servers, String topic, String apiKey, String apiSecret,
52 String consumerGroup, String consumerInstance, int fetchTimeout, int fetchLimit, boolean useHttps,
53 boolean allowSelfSignedCerts) {
55 super(servers, topic, apiKey, apiSecret, consumerGroup, consumerInstance, fetchTimeout, fetchLimit, useHttps,
56 allowSelfSignedCerts);
58 this.allowSelfSignedCerts = allowSelfSignedCerts;
64 * Initialize the Cambria client
68 this.consumer = new BusConsumer.CambriaConsumerWrapper(this.servers, this.topic, this.apiKey, this.apiSecret,
69 this.consumerGroup, this.consumerInstance, this.fetchTimeout, this.fetchLimit, this.useHttps,
70 this.allowSelfSignedCerts);
77 public CommInfrastructure getTopicCommInfrastructure() {
78 return Topic.CommInfrastructure.UEB;
83 public String toString() {
84 StringBuilder builder = new StringBuilder();
85 builder.append("SingleThreadedUebTopicSource [getTopicCommInfrastructure()=")
86 .append(getTopicCommInfrastructure()).append(", toString()=").append(super.toString()).append("]");
87 return builder.toString();