Copy policy-endpoints from drools-pdp to common

Issue-ID: POLICY-967
Change-Id: I374c155ee102c3e157c60d0a22d7191544abb76a
Signed-off-by: mmis <michael.morris@ericsson.com>

1 files changed, 127 insertions, 0 deletions

diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicBase.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicBase.java
new file mode 100644
index 00000000..7f4c0ddd
--- /dev/null
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicBase.java
@@ -0,0 +1,127 @@
+/*
+ * ============LICENSE_START=======================================================
+ * policy-endpoints
+ * ================================================================================
+ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.common.endpoints.event.comm.bus.internal;
+
+import java.util.List;
+
+import org.onap.policy.common.endpoints.event.comm.bus.ApiKeyEnabled;
+
+/**
+ * Bus Topic Base
+ */
+public abstract class BusTopicBase extends TopicBase implements ApiKeyEnabled {
+
+    /**
+     * API Key
+     */
+    protected String apiKey;
+
+    /**
+     * API Secret
+     */
+    protected String apiSecret;
+
+    /**
+     * Use https
+     */
+    protected boolean useHttps;
+
+    /**
+     * allow self signed certificates
+     */
+    protected boolean allowSelfSignedCerts;
+
+    /**
+     * Instantiates a new Bus Topic Base
+     * 
+     * @param servers list of servers
+     * @param topic topic name
+     * @param apiKey API Key
+     * @param apiSecret API Secret
+     * @param useHttps does connection use HTTPS?
+     * @param allowSelfSignedCerts are self-signed certificates allow
+     * 
+     * @return a Bus Topic Base
+     * @throws IllegalArgumentException if invalid parameters are present
+     */
+    public BusTopicBase(List<String> servers, String topic, String apiKey, String apiSecret, boolean useHttps,
+            boolean allowSelfSignedCerts) {
+
+        super(servers, topic);
+
+        this.apiKey = apiKey;
+        this.apiSecret = apiSecret;
+        this.useHttps = useHttps;
+        this.allowSelfSignedCerts = allowSelfSignedCerts;
+    }
+
+    @Override
+    public String getApiKey() {
+        return apiKey;
+    }
+
+    @Override
+    public String getApiSecret() {
+        return apiSecret;
+    }
+
+    /**
+     * @return if using https
+     */
+    public boolean isUseHttps() {
+        return useHttps;
+    }
+
+    /**
+     * @return if self signed certificates are allowed
+     */
+    public boolean isAllowSelfSignedCerts() {
+        return allowSelfSignedCerts;
+    }
+
+    protected boolean anyNullOrEmpty(String... args) {
+        for (String arg : args) {
+            if (arg == null || arg.isEmpty()) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    protected boolean allNullOrEmpty(String... args) {
+        for (String arg : args) {
+            if (!(arg == null || arg.isEmpty())) {
+                return false;
+            }
+        }
+
+        return true;
+    }
+
+
+    @Override
+    public String toString() {
+        return "BusTopicBase [apiKey=" + apiKey + ", apiSecret=" + apiSecret + ", useHttps=" + useHttps
+                + ", allowSelfSignedCerts=" + allowSelfSignedCerts + ", toString()=" + super.toString() + "]";
+    }
+
+}