1 files changed, 91 insertions, 0 deletions
diff --git a/policy-endpoints/src/main/java/org/openecomp/policy/drools/event/comm/bus/internal/InlineUebTopicSink.java b/policy-endpoints/src/main/java/org/openecomp/policy/drools/event/comm/bus/internal/InlineUebTopicSink.java
new file mode 100644
index 00000000..2d4b1552
--- /dev/null
+++ b/policy-endpoints/src/main/java/org/openecomp/policy/drools/event/comm/bus/internal/InlineUebTopicSink.java
@@ -0,0 +1,91 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * policy-endpoints
+ * ================================================================================
+ * Copyright (C) 2017 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.openecomp.policy.drools.event.comm.bus.internal;
+
+import java.util.List;
+
+import org.openecomp.policy.drools.event.comm.Topic;
+import org.openecomp.policy.drools.event.comm.bus.UebTopicSink;
+import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
+
+/**
+ * This implementation publishes events for the associated UEB topic,
+ * inline with the calling thread.
+ */
+public class InlineUebTopicSink extends InlineBusTopicSink implements UebTopicSink {
+	
+	/**
+	 * logger 
+	 */
+	private static org.openecomp.policy.common.logging.flexlogger.Logger logger = 
+										FlexLogger.getLogger(InlineUebTopicSink.class);
+	
+	/**
+	 * Argument-based UEB Topic Writer instantiation
+	 * 
+	 * @param servers list of UEB servers available for publishing
+	 * @param topic the topic to publish to
+	 * @param apiKey the api key (optional)
+	 * @param apiSecret the api secret (optional)
+	 * @param partitionId the partition key (optional, autogenerated if not provided)
+	 * 
+	 * @throws IllegalArgumentException if invalid arguments are detected
+	 */
+	public InlineUebTopicSink(List<String> servers, 
+								String topic, 
+            					String apiKey, 
+            					String apiSecret,
+            					String partitionId) 
+    throws IllegalArgumentException {		
+		super(servers, topic, apiKey, apiSecret, partitionId);
+	}
+	
+	/**
+	 * Instantiation of internal resources
+	 */
+	@Override
+	public void init() {	
+		
+		this.publisher = 
+				new BusPublisher.CambriaPublisherWrapper(this.servers, 
+						                                 this.topic, 
+						                                 this.apiKey, 
+						                                 this.apiSecret);
+		if (logger.isInfoEnabled())
+			logger.info("UEB SINK TOPIC created " + this);
+	}
+	
+	@Override
+	public String toString() {
+		StringBuilder builder = new StringBuilder();
+		builder.append("InlineUebTopicSink [getTopicCommInfrastructure()=").append(getTopicCommInfrastructure())
+				.append(", toString()=").append(super.toString()).append("]");
+		return builder.toString();
+	}
+
+	/**
+	 * {@inheritDoc}
+	 */
+	@Override
+	public CommInfrastructure getTopicCommInfrastructure() {
+		return Topic.CommInfrastructure.UEB;
+	}
+}