Initial commit for OpenECOMP SDN-C northbound

Change-Id: Iffe4d4fbcfd21ecbc1000238354094cc064298ce
Signed-off-by: Dan Timoney <dtimoney@att.com>

13 files changed, 1560 insertions, 0 deletions

diff --git a/ueb-listener/.gitignore b/ueb-listener/.gitignore
new file mode 100755
index 00000000..1b8a6ba9
--- /dev/null
+++ b/ueb-listener/.gitignore
@@ -0,0 +1,12 @@
+org.eclipse.core.resources.prefs
+.classpath

+.project

+.settings

+.idea

+.externalToolBuilders

+maven-eclipse.xml

+*.class

+target/

+MANIFEST.MF

+.DS_STORE

+.metadata

diff --git a/ueb-listener/.sonar/checkstyle.xml b/ueb-listener/.sonar/checkstyle.xml
new file mode 100755
index 00000000..3fa23153
--- /dev/null
+++ b/ueb-listener/.sonar/checkstyle.xml
@@ -0,0 +1 @@
+<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE module PUBLIC "-//Puppy Crawl//DTD Check Configuration 1.2//EN" "http://www.puppycrawl.com/dtds/configuration_1_2.dtd"><!-- Generated by Sonar --><module name="Checker"><module name="SuppressionCommentFilter"/><module name="TreeWalker"><module name="FileContentsHolder"/> <module name="ClassFanOutComplexity"><property name="severity" value="warning"/></module><module name="NestedForDepth"><property name="severity" value="warning"/><property name="max" value="1"/></module><module name="ClassDataAbstractionCoupling"><property name="severity" value="warning"/></module></module></module>
\ No newline at end of file
diff --git a/ueb-listener/.sonar/pmd.xml b/ueb-listener/.sonar/pmd.xml
new file mode 100755
index 00000000..80343b3b
--- /dev/null
+++ b/ueb-listener/.sonar/pmd.xml
@@ -0,0 +1,67 @@
+<?xml version="1.0" encoding="UTF-8"?>

+<ruleset>

+  <rule ref="rulesets/java/naming.xml/BooleanGetMethodName">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/j2ee.xml/StaticEJBFieldShouldBeFinal">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/coupling.xml/CouplingBetweenObjects">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/codesize.xml/TooManyMethods">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/naming.xml/AvoidFieldNameMatchingTypeName">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/basic.xml/DoubleCheckedLocking">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/naming.xml/AvoidFieldNameMatchingMethodName">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/coupling.xml/ExcessiveImports">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/basic.xml/OverrideBothEqualsAndHashcode">

+    <priority>2</priority>

+  </rule>

+  <rule ref="rulesets/java/naming.xml/ShortMethodName">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/basic.xml/BooleanInstantiation">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/codesize.xml/TooManyFields">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/controversial.xml/AvoidUsingNativeCode">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/optimizations.xml/UseStringBufferForStringAppends">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/coupling.xml/LooseCoupling">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/design.xml/NonThreadSafeSingleton">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/j2ee.xml/DoNotUseThreads">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/sunsecure.xml/ArrayIsStoredDirectly">

+    <priority>5</priority>

+  </rule>

+  <rule ref="rulesets/java/sunsecure.xml/MethodReturnsInternalArray">

+    <priority>2</priority>

+  </rule>

+  <rule ref="rulesets/java/design.xml/AssignmentToNonFinalStatic">

+    <priority>3</priority>

+  </rule>

+  <rule ref="rulesets/java/strictexception.xml/AvoidCatchingGenericException">

+    <priority>3</priority>

+  </rule>

+</ruleset>

+

diff --git a/ueb-listener/pom.xml b/ueb-listener/pom.xml
new file mode 100755
index 00000000..ae740bb9
--- /dev/null
+++ b/ueb-listener/pom.xml
@@ -0,0 +1,110 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+    <groupId>org.openecomp.sdnc.northbound</groupId>
+	<packaging>jar</packaging>
+	<artifactId>ueb-listener</artifactId>
+	<version>1.0.0</version>
+
+	<name>UEB Listener</name>
+	<description>UEB Listener</description>
+	<parent>
+		<groupId>org.openecomp.sdnc.northbound</groupId>
+		<artifactId>sdnc-northbound</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<properties>
+		<sdc.client.version>1.1.0</sdc.client.version>
+		<skip.SWM>true</skip.SWM>
+		<ueb.listener.base>/opt/app/ueb-listener</ueb.listener.base>
+		<maven.build.timestamp.format>yyMMdd-HHmmss</maven.build.timestamp.format>
+		<build.number>${maven.build.timestamp}</build.number>
+		<SWM_VERSION>${project.version}-${build.number}</SWM_VERSION>
+	</properties>
+
+	<dependencies>
+
+		<dependency>
+			<groupId>org.openecomp.sdc</groupId>
+			<artifactId>sdc-distribution-client</artifactId>
+			<version>${sdc.client.version}</version>
+			<scope>compile</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+			<version>1.7.10</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-log4j12</artifactId>
+			<version>1.6.1</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>log4j</groupId>
+			<artifactId>log4j</artifactId>
+			<version>1.2.17</version>
+		</dependency>
+		<dependency>
+		<groupId>commons-codec</groupId>
+		<artifactId>commons-codec</artifactId>
+		<version>${commons.codec.version}</version>
+		</dependency>
+	</dependencies>
+	<build>
+		<plugins>
+
+			<!-- ================================================== -->
+			<!-- Set the JDK compiler version. -->
+			<!-- ================================================== -->
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>2.5.1</version>
+				<inherited>true</inherited>
+				<configuration>
+					<source>1.7</source>
+					<target>1.7</target>
+				</configuration>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-jar-plugin</artifactId>
+				<version>2.6</version>
+				<configuration>
+					<archive>
+						<manifest>
+							<addClasspath>true</addClasspath>
+							<mainClass>org.openecomp.sdnc.uebclient.SdncUebClient</mainClass>
+						</manifest>
+					</archive>
+				</configuration>
+			</plugin>
+
+			<plugin>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<executions>
+					<execution>
+						<id>create-zip</id>
+						<goals>
+							<goal>single</goal>
+						</goals>
+						<phase>package</phase>
+						<configuration>
+							<attach>true</attach>
+							<finalName>${project.artifactId}.${project.version}</finalName>
+							<attach>true</attach>
+							<descriptors>
+								<descriptor>src/assembly/assemble_zip.xml</descriptor>
+							</descriptors>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+
+		</plugins>
+	</build>
+
+</project>
diff --git a/ueb-listener/src/assembly/assemble_zip.xml b/ueb-listener/src/assembly/assemble_zip.xml
new file mode 100644
index 00000000..f87a6488
--- /dev/null
+++ b/ueb-listener/src/assembly/assemble_zip.xml
@@ -0,0 +1,61 @@
+<!--
+  ============LICENSE_START=======================================================
+  openECOMP : SDN-C
+  ================================================================================
+  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=========================================================
+  -->
+
+<!-- Defines how we build the .zip file which is our distribution. -->
+
+<assembly
+	xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd">
+	<formats>
+		<format>zip</format>
+	</formats>
+
+	<includeBaseDirectory>false</includeBaseDirectory>
+
+	<fileSets>
+		<fileSet>
+			<directory>src/main/bin</directory>
+			<outputDirectory>bin</outputDirectory>
+		</fileSet>
+		<fileSet>
+			<directory>target</directory>
+			<outputDirectory>lib</outputDirectory>
+			<includes>
+				<include>*.jar</include>
+			</includes>
+		</fileSet>
+		<fileSet>
+			<directory>src/main/resources</directory>
+			<outputDirectory>lib</outputDirectory>
+			<includes>
+				<include>*.xslt</include>
+			</includes>
+		</fileSet>
+	</fileSets>
+	<dependencySets>
+		<dependencySet>
+			<outputDirectory>lib</outputDirectory>
+			<useProjectArtifact>true</useProjectArtifact>
+			<scope>runtime</scope>
+		</dependencySet>
+	</dependencySets>
+</assembly>
diff --git a/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebCallback.java b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebCallback.java
new file mode 100644
index 00000000..3fa752bc
--- /dev/null
+++ b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebCallback.java
@@ -0,0 +1,840 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * 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.sdnc.uebclient;
+
+import java.io.BufferedReader;
+import java.io.ByteArrayInputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.Authenticator;
+import java.net.HttpURLConnection;
+import java.net.PasswordAuthentication;
+import java.net.URL;
+import java.nio.file.DirectoryStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.StandardCopyOption;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.LinkedList;
+import java.util.List;
+
+import javax.net.ssl.HostnameVerifier;
+import javax.net.ssl.HttpsURLConnection;
+import javax.net.ssl.SSLSession;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.transform.Source;
+import javax.xml.transform.Transformer;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.stream.StreamResult;
+import javax.xml.transform.stream.StreamSource;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathFactory;
+
+import org.apache.commons.codec.binary.Base64;
+import org.openecomp.sdc.api.IDistributionClient;
+import org.openecomp.sdc.api.consumer.IDistributionStatusMessage;
+import org.openecomp.sdc.api.consumer.INotificationCallback;
+import org.openecomp.sdc.api.notification.IArtifactInfo;
+import org.openecomp.sdc.api.notification.INotificationData;
+import org.openecomp.sdc.api.notification.IResourceInstance;
+import org.openecomp.sdc.api.results.IDistributionClientDownloadResult;
+import org.openecomp.sdc.api.results.IDistributionClientResult;
+import org.openecomp.sdc.utils.ArtifactTypeEnum;
+import org.openecomp.sdc.utils.DistributionActionResultEnum;
+import org.openecomp.sdc.utils.DistributionStatusEnum;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+public class SdncUebCallback implements INotificationCallback {
+
+    private static final Logger LOG = LoggerFactory
+            .getLogger(SdncUebCallback.class);
+
+    private static final int NUM_PASSES = 2;
+
+    private enum SdncArtifactType {
+        VF_LICENSE_MODEL("vf-license-model", "vf-license-model-update",0),
+        UNKNOWN("","",0);
+
+
+        private String tag;
+        private String rpcName;
+        private int pass;
+
+        public int getPass() {
+            return pass;
+        }
+
+        private SdncArtifactType(String tag, String rpcName, int pass) {
+            this.tag = tag;
+            this.rpcName = rpcName;
+            this.pass = pass;
+        }
+
+        public String getTag() {
+            return tag;
+        }
+
+        public String getRpcUrl(String base) {
+            return base+rpcName;
+        }
+
+        public static SdncArtifactType fromTag(String tag) {
+            if (tag != null) {
+                for (SdncArtifactType artifact: SdncArtifactType.values()) {
+                    if (artifact.getTag().equalsIgnoreCase(tag)) {
+                        return artifact;
+                    }
+                }
+            }
+
+            return UNKNOWN;
+        }
+    }
+
+    private class SdncAuthenticator extends Authenticator {
+
+        private final String user;
+        private final String passwd;
+
+        SdncAuthenticator(String user, String passwd) {
+            this.user = user;
+            this.passwd = passwd;
+        }
+        @Override
+        protected PasswordAuthentication getPasswordAuthentication() {
+            return new PasswordAuthentication(user, passwd.toCharArray());
+        }
+
+    }
+
+    private class DeployableArtifact {
+        SdncArtifactType type;
+        IArtifactInfo artifactInfo;
+        String svcName;
+        String resourceName;
+        String artifactName;
+        String artifactVersion;
+        File file;
+
+        public String getArtifactName() {
+            return artifactName;
+        }
+
+
+
+        public String getArtifactVersion() {
+            return artifactVersion;
+        }
+
+
+        public SdncArtifactType getType() {
+            return type;
+        }
+
+
+
+        public IArtifactInfo getArtifactInfo() {
+            return artifactInfo;
+        }
+
+
+        public File getFile() {
+            return file;
+        }
+
+
+
+
+        public DeployableArtifact(SdncArtifactType type, String svcName, String resourceName, IArtifactInfo artifactInfo, File file) {
+            this.type = type;
+            this.artifactInfo = artifactInfo;
+            this.artifactName = artifactInfo.getArtifactName();
+            this.artifactVersion = artifactInfo.getArtifactVersion();
+            this.file = file;
+        }
+
+
+        public DeployableArtifact(SdncArtifactType type, String svcName, String resourceName, String artifactName, String artifactVersion, File file) {
+            this.type = type;
+            this.artifactInfo = null;
+            this.artifactName = artifactName;
+            this.artifactVersion = artifactVersion;
+            this.file = file;
+        }
+
+
+
+        public String getSvcName() {
+            return svcName;
+        }
+
+
+
+        public String getResourceName() {
+            return resourceName;
+        }
+
+    }
+
+    private final IDistributionClient client;
+    private final SdncUebConfiguration config;
+
+    private final LinkedList<DeployableArtifact> deployList[];
+
+
+    public SdncUebCallback(IDistributionClient client, SdncUebConfiguration config) {
+        this.client = client;
+        this.config = config;
+        this.deployList = new LinkedList[NUM_PASSES];
+
+        for (int i = 0 ; i < NUM_PASSES ; i++) {
+            this.deployList[i] = new LinkedList<>();
+        }
+    }
+
+    @Override
+	public void activateCallback(INotificationData data) {
+
+        LOG.info("Received notification : ("+data.getDistributionID()+","+data.getServiceName()+","+data.getServiceVersion()+
+                ","+data.getServiceDescription());
+
+        String incomingDirName = config.getIncomingDir();
+        String archiveDirName = config.getArchiveDir();
+
+        File incomingDir = null;
+        File archiveDir = null;
+
+        if (!incomingDir.exists()) {
+            incomingDir.mkdirs();
+        }
+
+
+        if (!archiveDir.exists()) {
+            archiveDir.mkdirs();
+        }
+
+        // Process service level artifacts
+        List<IArtifactInfo> artifactList = data.getServiceArtifacts();
+
+        if (artifactList != null) {
+
+            incomingDir = new File(incomingDirName + "/" + escapeFilename(data.getServiceName()));
+            if (!incomingDir.exists()) {
+                incomingDir.mkdirs();
+            }
+
+            archiveDir = new File(archiveDirName + "/" + escapeFilename(data.getServiceName()));
+            if (!archiveDir.exists()) {
+                archiveDir.mkdirs();
+            }
+            for (IArtifactInfo curArtifact : artifactList)
+            {
+
+                LOG.info("Received artifact " + curArtifact.getArtifactName());
+
+                handleArtifact(data, data.getServiceName(), null, curArtifact, incomingDir, archiveDir);
+            }
+        }
+
+
+        // Process resource level artifacts
+        for (IResourceInstance curResource : data.getResources()) {
+
+            LOG.info("Received resource : "+curResource.getResourceName());
+            artifactList = curResource.getArtifacts();
+
+            if (artifactList != null) {
+
+                incomingDir = new File(incomingDirName + "/" + escapeFilename(data.getServiceName()) + "/" + escapeFilename(curResource.getResourceName()));
+                if (!incomingDir.exists()) {
+                    incomingDir.mkdirs();
+                }
+
+                archiveDir = new File(archiveDirName + "/" + escapeFilename(data.getServiceName()) + "/" + escapeFilename(curResource.getResourceName()));
+                if (!archiveDir.exists()) {
+                    archiveDir.mkdirs();
+                }
+                for (IArtifactInfo curArtifact : artifactList)
+                {
+
+                    LOG.info("Received artifact " + curArtifact.getArtifactName());
+
+                    handleArtifact(data, data.getServiceName(), curResource.getResourceName(), curArtifact, incomingDir, archiveDir);
+                }
+            }
+        }
+
+        deployDownloadedFiles(incomingDir, archiveDir, data);
+
+
+    }
+
+
+    public void deployDownloadedFiles(File incomingDir, File archiveDir, INotificationData data) {
+
+        if (incomingDir == null) {
+            incomingDir = new File(config.getIncomingDir());
+
+            if (!incomingDir.exists()) {
+                incomingDir.mkdirs();
+            }
+
+        }
+
+        if (archiveDir == null) {
+            archiveDir = new File(config.getArchiveDir());
+
+            if (!archiveDir.exists()) {
+                archiveDir.mkdirs();
+            }
+        }
+
+        String curFileName = "";
+        try (DirectoryStream<Path> stream = Files.newDirectoryStream(incomingDir.toPath())) {
+            for (Path file: stream) {
+                curFileName = file.toString();
+                handleSuccessfulDownload(null,null, null, null, file.toFile(), archiveDir);
+            }
+        } catch (Exception x) {
+            // IOException can never be thrown by the iteration.
+            // In this snippet, it can only be thrown by newDirectoryStream.
+            LOG.warn("Cannot process spool file "+ curFileName, x);
+        }
+
+        // Deploy scheduled deployments
+
+        for (int pass = 0 ; pass < NUM_PASSES ; pass++) {
+
+            if (deployList[pass] != null) {
+                while (! deployList[pass].isEmpty()) {
+                    DeployableArtifact artifact = deployList[pass].pop();
+
+                    DistributionStatusEnum deployResult = DistributionStatusEnum.DEPLOY_ERROR;
+
+
+                    try {
+
+                        deployResult = deploySpoolFile(artifact);
+                    } catch (Exception e) {
+                        LOG.error("Caught exception trying to deploy file", e);
+                    }
+
+
+                    IArtifactInfo artifactInfo = artifact.getArtifactInfo();
+
+                    if (artifactInfo != null && data != null) {
+                        IDistributionClientResult deploymentStatus;
+                            deploymentStatus = client.sendDeploymentStatus(buildStatusMessage(
+                                    client, data, artifactInfo,
+                                    deployResult));
+                    }
+
+                }
+            }
+        }
+    }
+
+    private void handleArtifact(INotificationData data, String svcName, String resourceName, IArtifactInfo artifact, File incomingDir, File archiveDir) {
+
+        // Download Artifact
+        IDistributionClientDownloadResult downloadResult = client
+                .download(artifact);
+
+        String payload = new String(downloadResult.getArtifactPayload());
+
+
+        File spoolFile = new File(incomingDir.getAbsolutePath() + "/" + artifact.getArtifactName());
+
+        boolean writeSucceeded = false;
+
+        try {
+            FileWriter spoolFileWriter = new FileWriter(spoolFile);
+            spoolFileWriter.write(payload);
+            spoolFileWriter.close();
+            writeSucceeded = true;
+        } catch (Exception e) {
+            LOG.error("Unable to save downloaded file to spool directory ("+ incomingDir.getAbsolutePath() +")", e);
+        }
+
+
+        if (writeSucceeded && downloadResult.getDistributionActionResult() == DistributionActionResultEnum.SUCCESS) {
+            handleSuccessfulDownload(data, svcName, resourceName, artifact, spoolFile, archiveDir);
+
+
+        } else {
+            handleFailedDownload(data, artifact);
+        }
+
+    }
+
+    private void handleFailedDownload(INotificationData data,
+            IArtifactInfo relevantArtifact) {
+        // Send Download Status
+        IDistributionClientResult sendDownloadStatus = client
+                .sendDownloadStatus(buildStatusMessage(client, data,
+                        relevantArtifact, DistributionStatusEnum.DOWNLOAD_ERROR));
+    }
+
+    private void handleSuccessfulDownload(INotificationData data, String svcName, String resourceName,
+            IArtifactInfo artifact, File spoolFile, File archiveDir) {
+
+        if (data != null && artifact != null) {
+            // Send Download Status
+            IDistributionClientResult sendDownloadStatus = client
+                    .sendDownloadStatus(buildStatusMessage(client, data, artifact, DistributionStatusEnum.DOWNLOAD_OK));
+        }
+
+        // If an override file exists, read that instead of the file we just downloaded
+        ArtifactTypeEnum artifactEnum = ArtifactTypeEnum.YANG_XML;
+
+        if (artifact != null) {
+                artifact.getArtifactType();
+        }
+        String overrideFileName = config.getOverrideFile();
+        if (overrideFileName != null && overrideFileName.length() > 0) {
+            File overrideFile = new File(overrideFileName);
+
+            if (overrideFile.exists()) {
+                artifactEnum = ArtifactTypeEnum.YANG_XML;
+                spoolFile = overrideFile;
+            }
+
+        }
+
+        // Process spool file
+        Document spoolDoc = null;
+        File transformedFile = null;
+
+        // Apply XSLTs and get Doc object
+        try {
+            transformedFile = applyXslts(spoolFile);
+        } catch (Exception e) {
+            LOG.error("Caught exception trying to parse XML file", e);
+        }
+
+        if (transformedFile != null) {
+            try {
+
+                try {
+
+                    DocumentBuilderFactory dbf = DocumentBuilderFactory
+                            .newInstance();
+                    DocumentBuilder db = dbf.newDocumentBuilder();
+
+                    spoolDoc = db.parse(transformedFile);
+                } catch (Exception e) {
+                    LOG.error(
+                            "Caught exception trying to parse transformed XML file "
+                                    + transformedFile.getAbsolutePath(), e);
+                }
+
+            } catch (Exception e) {
+                LOG.error("Caught exception trying to deploy file", e);
+            }
+        }
+
+
+        if (spoolDoc != null) {
+            // Analyze file type
+            SdncArtifactType artifactType = analyzeFileType(artifactEnum,
+                    spoolFile, spoolDoc);
+
+            if (artifactType != SdncArtifactType.UNKNOWN) {
+
+                scheduleDeployment(artifactType, svcName, resourceName, artifact, spoolFile.getName(), transformedFile);
+
+            }
+
+            // SDNGC-2660 : Move file to archive directory even if it is an unrecognized type so that
+            // we do not keep trying and failing to process it.
+            try {
+                Path source = spoolFile.toPath();
+                Path targetDir = archiveDir.toPath();
+
+                Files.move(source, targetDir.resolve(source.getFileName()), StandardCopyOption.REPLACE_EXISTING);
+            } catch (IOException e) {
+                LOG.warn("Could not move "+spoolFile.getAbsolutePath()+" to "+archiveDir.getAbsolutePath(), e);
+            }
+        }
+
+
+    }
+
+
+    private SdncArtifactType analyzeFileType(ArtifactTypeEnum artifactType, File spoolFile, Document spoolDoc) {
+
+        if (artifactType != ArtifactTypeEnum.YANG_XML) {
+            LOG.error("Unexpected artifact type - expecting YANG_XML, got "+artifactType);
+            return SdncArtifactType.UNKNOWN;
+        }
+
+        // Examine outer tag
+
+        try {
+
+
+            Element root = spoolDoc.getDocumentElement();
+
+            String rootName = root.getTagName();
+
+            if (rootName.contains(":")) {
+                String[] rootNameElems = rootName.split(":");
+                rootName = rootNameElems[rootNameElems.length - 1];
+            }
+
+            if (rootName != null) {
+                SdncArtifactType retValue = SdncArtifactType.fromTag(rootName);
+
+                if (retValue == SdncArtifactType.UNKNOWN) {
+
+                    LOG.error("Unexpected file contents - root tag is "+rootName);
+                }
+                return retValue;
+            } else {
+                LOG.error("Cannot get root tag from file");
+                return SdncArtifactType.UNKNOWN;
+            }
+
+        } catch (Exception e) {
+            LOG.error("Could not parse YANG_XML file "+spoolFile.getName(), e);
+            return SdncArtifactType.UNKNOWN;
+        }
+    }
+
+    private void scheduleDeployment(SdncArtifactType type, String svcName, String resourceName, IArtifactInfo artifactInfo, String spoolFileName, File spoolFile) {
+
+        if (type.getPass() < deployList.length) {
+
+            if (artifactInfo != null) {
+                LOG.debug("Scheduling "+artifactInfo.getArtifactName()+" version "+artifactInfo.getArtifactVersion()+" for deployment");
+
+                deployList[type.getPass()].add(new DeployableArtifact(type, svcName, resourceName, artifactInfo, spoolFile));
+            } else {
+                SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd_HH:mm:ss.SSS");//dd/MM/yyyy
+                Date now = new Date();
+                String artifactVersion = sdfDate.format(now);
+                LOG.debug("Scheduling "+spoolFileName+" version "+artifactVersion+" for deployment");
+                String artifactName = spoolFileName;
+                if (artifactInfo != null) {
+                    artifactName = artifactInfo.getArtifactName();
+                }
+                deployList[type.getPass()].add(new DeployableArtifact(type, svcName, resourceName, artifactName, artifactVersion, spoolFile));
+            }
+        } else {
+            LOG.info("Pass for type "+type.getTag()+" is "+type.getPass()+" which is not <= "+deployList.length);
+        }
+    }
+
+
+    private DistributionStatusEnum deploySpoolFile(DeployableArtifact artifact) {
+
+        DistributionStatusEnum deployResult = DistributionStatusEnum.DEPLOY_OK;
+
+        StringBuffer msgBuffer = new StringBuffer();
+
+
+        String namespace = config.getAsdcApiNamespace();
+        if (namespace == null || namespace.length() == 0) {
+            namespace="com:att:sdnctl:asdcapi";
+        }
+
+        msgBuffer.append("<input xmlns='");
+        msgBuffer.append(namespace);
+        msgBuffer.append("'>\n");
+
+        String svcName = artifact.getSvcName();
+        String resourceName = artifact.getResourceName();
+        String artifactName = artifact.getArtifactName();
+
+        if (svcName != null) {
+            if (resourceName != null) {
+                artifactName = svcName + "/" + resourceName + "/" + artifactName;
+            } else {
+                artifactName = svcName + "/" + artifactName;
+            }
+        }
+
+        msgBuffer.append("<artifact-name>"+artifactName+"</artifact-name>\n");
+        msgBuffer.append("<artifact-version>"+artifact.getArtifactVersion()+"</artifact-version>\n");
+
+
+        try {
+            BufferedReader rdr = new BufferedReader(new FileReader(artifact.getFile()));
+
+            String curLine = rdr.readLine();
+
+            while (curLine != null) {
+
+                if (!curLine.startsWith("<?")) {
+                    msgBuffer.append(curLine+"\n");
+                }
+                curLine = rdr.readLine();
+            }
+            rdr.close();
+
+        } catch (Exception e) {
+            LOG.error("Could not process spool file "+artifact.getFile().getName(), e);
+            return DistributionStatusEnum.DEPLOY_ERROR;
+        }
+
+        msgBuffer.append("</input>\n");
+
+
+        byte[] msgBytes = msgBuffer.toString().getBytes();
+
+        Document results = postRestXml(artifact.getType().getRpcUrl(config.getAsdcApiBaseUrl()), msgBytes);
+
+        if (results == null) {
+
+            deployResult = DistributionStatusEnum.DEPLOY_ERROR;
+        } else {
+
+            XPathFactory xpf = XPathFactory.newInstance();
+            XPath xp = xpf.newXPath();
+
+            String asdcApiResponseCode = "500";
+
+            try {
+
+                asdcApiResponseCode = xp.evaluate("//asdc-api-response-code[position()=1]/text()", results.getDocumentElement());
+            } catch (Exception e) {
+                LOG.error("Caught exception retrying to evaluate xpath", e);
+            }
+
+            if (asdcApiResponseCode.contains("200")) {
+                LOG.info("Update to SDN-C succeeded");
+                deployResult = DistributionStatusEnum.DEPLOY_OK;
+            } else {
+                LOG.info("Update to SDN-C failed (response code "+asdcApiResponseCode+")");
+
+                if (asdcApiResponseCode.contains("409")) {
+                    deployResult = DistributionStatusEnum.ALREADY_DEPLOYED;
+                } else {
+
+                    deployResult = DistributionStatusEnum.DEPLOY_ERROR;
+                }
+            }
+        }
+
+
+
+        return deployResult;
+    }
+
+
+
+
+
+    public static IDistributionStatusMessage buildStatusMessage(
+            final IDistributionClient client, final INotificationData data,
+            final IArtifactInfo relevantArtifact,
+            final DistributionStatusEnum status) {
+        IDistributionStatusMessage statusMessage = new IDistributionStatusMessage() {
+
+            @Override
+			public long getTimestamp() {
+                long currentTimeMillis = System.currentTimeMillis();
+                return currentTimeMillis;
+            }
+
+            @Override
+			public DistributionStatusEnum getStatus() {
+                return status;
+            }
+
+            @Override
+			public String getDistributionID() {
+                return data.getDistributionID();
+            }
+
+            @Override
+			public String getConsumerID() {
+                return client.getConfiguration().getConsumerID();
+            }
+
+            @Override
+			public String getArtifactURL() {
+                return relevantArtifact.getArtifactURL();
+            }
+        };
+        return statusMessage;
+
+    }
+
+    private HttpURLConnection getRestXmlConnection(String urlString, String method) throws IOException
+    {
+        URL sdncUrl = new URL(urlString);
+        Authenticator.setDefault(new SdncAuthenticator(config.getSdncUser(), config.getSdncPasswd()));
+
+        HttpURLConnection conn = (HttpURLConnection) sdncUrl.openConnection();
+
+        String authStr = config.getSdncUser()+":"+config.getSdncPasswd();
+        String encodedAuthStr = new String(Base64.encodeBase64(authStr.getBytes()));
+
+        conn.addRequestProperty("Authentication", "Basic "+encodedAuthStr);
+
+        conn.setRequestMethod(method);
+        conn.setRequestProperty("Content-Type", "application/xml");
+        conn.setRequestProperty("Accept", "application/xml");
+
+        conn.setDoInput(true);
+        conn.setDoOutput(true);
+        conn.setUseCaches(false);
+
+        return conn;
+
+    }
+
+    private Document postRestXml(String urlString, byte[] msgBytes) {
+        Document response = null;
+
+        LOG.info("Sending REST POST to "+urlString);
+        LOG.info("Message body:\n"+new String(msgBytes));
+
+        try {
+            HttpURLConnection conn = getRestXmlConnection(urlString, "POST");
+
+            if (conn instanceof HttpsURLConnection) {
+                HostnameVerifier hostnameVerifier = new HostnameVerifier() {
+                    @Override
+                    public boolean verify(String hostname, SSLSession session) {
+                        return true;
+                    }
+                };
+                ((HttpsURLConnection)conn).setHostnameVerifier(hostnameVerifier);
+            }
+
+            // Write message
+            conn.setRequestProperty("Content-Length", ""+msgBytes.length);
+            DataOutputStream outStr = new DataOutputStream(conn.getOutputStream());
+            outStr.write(msgBytes);
+            outStr.close();
+
+
+            // Read response
+            BufferedReader respRdr;
+
+            LOG.info("Response: "+conn.getResponseCode()+" "+conn.getResponseMessage());
+
+
+            if (conn.getResponseCode() < 300) {
+
+                respRdr = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+            } else {
+                respRdr = new BufferedReader(new InputStreamReader(conn.getErrorStream()));
+            }
+
+            StringBuffer respBuff = new StringBuffer();
+
+            String respLn;
+
+            while ((respLn = respRdr.readLine()) != null) {
+                respBuff.append(respLn+"\n");
+            }
+            respRdr.close();
+
+            String respString = respBuff.toString();
+
+            LOG.info("Response body :\n"+respString);
+
+            DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
+            DocumentBuilder db = dbf.newDocumentBuilder();
+
+
+            response = db.parse(new ByteArrayInputStream(respString.getBytes()));
+
+        } catch (Exception e) {
+
+            LOG.error("Caught exception in postRestXml", e);
+        }
+
+        return response;
+    }
+
+    private File applyXslts(File srcFile) {
+
+        Document doc = null;
+
+
+        File inFile = srcFile;
+        File outFile = null;
+
+        String xsltPathList = config.getXsltPathList();
+
+        if (xsltPathList == null || xsltPathList.length() == 0) {
+            outFile = inFile;
+        } else {
+
+            String[] xsltPaths = xsltPathList.split(",");
+
+            for (String xsltPath : xsltPaths) {
+                try{
+
+                    outFile = File.createTempFile("tmp", "xml");
+                    TransformerFactory factory = TransformerFactory.newInstance();
+                    Source xslt = new StreamSource(new File(xsltPath));
+                    Transformer transformer = factory.newTransformer(xslt);
+                    Source text = new StreamSource(inFile);
+
+
+                    transformer.transform(text, new StreamResult(outFile));
+
+                    inFile = outFile;
+
+                } catch (Exception e) {
+                    LOG.error("Caught exception trying to apply XSLT template "+xsltPath, e);
+
+                }
+
+            }
+        }
+
+        // After transformations, parse transformed XML
+
+
+        return outFile;
+    }
+
+    private String escapeFilename(String str) {
+        StringBuffer retval = new StringBuffer();
+
+        for (int i = 0 ; i < str.length() ; i++) {
+            char curchar = str.charAt(i);
+            if (Character.isJavaIdentifierPart(curchar)) {
+                retval.append(curchar);
+            }
+        }
+
+        return retval.toString();
+
+    }
+
+}
diff --git a/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebClient.java b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebClient.java
new file mode 100644
index 00000000..dd6c5148
--- /dev/null
+++ b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebClient.java
@@ -0,0 +1,65 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * 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.sdnc.uebclient;
+
+import org.openecomp.sdc.api.IDistributionClient;
+import org.openecomp.sdc.api.results.IDistributionClientResult;
+import org.openecomp.sdc.impl.DistributionClientFactory;
+import org.openecomp.sdc.utils.DistributionActionResultEnum;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SdncUebClient {
+
+	private static final Logger LOG = LoggerFactory
+			.getLogger(SdncUebConfiguration.class);
+
+	public static void main(String[] args) {
+		IDistributionClient client = DistributionClientFactory
+				.createDistributionClient();
+
+		SdncUebConfiguration config = new SdncUebConfiguration();
+
+		SdncUebCallback cb = new SdncUebCallback(client, config);
+
+		LOG.info("Scanning for local distribution artifacts before starting client");
+		cb.deployDownloadedFiles(null, null, null);
+
+		LOG.info("Initializing ASDC distribution client");
+
+		IDistributionClientResult result = client.init(
+				config, cb);
+
+		LOG.info("Initialized ASDC distribution client - results = "
+				+ result.getDistributionMessageResult());
+
+		if (result.getDistributionActionResult() == DistributionActionResultEnum.SUCCESS) {
+			LOG.info("Starting client...");
+			IDistributionClientResult start = client.start();
+			LOG.info("Client startup result = "
+					+ start.getDistributionMessageResult());
+		}
+
+
+	}
+
+}
diff --git a/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebConfiguration.java b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebConfiguration.java
new file mode 100644
index 00000000..b7d9b983
--- /dev/null
+++ b/ueb-listener/src/main/java/org/openecomp/sdnc/uebclient/SdncUebConfiguration.java
@@ -0,0 +1,260 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * 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.sdnc.uebclient;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Properties;
+
+import org.openecomp.sdc.api.consumer.IConfiguration;
+import org.openecomp.sdc.utils.ArtifactTypeEnum;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SdncUebConfiguration implements IConfiguration{
+
+	private static final String SDNC_CONFIG_DIR = "SDNC_CONFIG_DIR";
+	private static final Logger LOG = LoggerFactory
+			.getLogger(SdncUebConfiguration.class);
+
+	private String asdcAddress = null;
+	private String consumerGroup = null;
+	private String consumerID = null;
+	private String environmentName = null;
+	private String password = null;
+	private int pollingInterval = 30;
+	private int pollingTimeout = 15;
+	private List<String> relevantArtifactTypes = null;
+	private String user = null;
+
+	private String sdncUser = null;
+	private String sdncPasswd = null;
+	private String asdcApiBaseUrl = null;
+	private String asdcApiNamespace = null;
+
+	public String getAsdcApiNamespace() {
+		return asdcApiNamespace;
+	}
+
+	private String incomingDir = null;
+
+	private String archiveDir = null;
+
+	private String overrideFile = null;
+
+	private boolean activateServerTLSAuth;
+	private String keyStorePassword;
+	private String keyStorePath;
+
+	private String xsltPathList;
+
+	public String getXsltPathList() {
+		return xsltPathList;
+	}
+
+	public String getOverrideFile() {
+		return overrideFile;
+	}
+
+	public SdncUebConfiguration() {
+
+		try {
+			init();
+		} catch (Exception e) {
+			LOG.error("Cannot initialize SdncUebConfiguration", e);
+		}
+	}
+
+	public void init() throws IOException {
+		String propPath = null;
+		String propDir = System.getenv(SDNC_CONFIG_DIR);
+		if (propDir == null) {
+
+			propDir = "/opt/sdnc/data/properties";
+		}
+		propPath = propDir + "/ueb-listener.properties";
+		File propFile = new File(propPath);
+
+
+		if (!propFile.exists()) {
+
+			throw new FileNotFoundException(
+					"Missing configuration properties file : "
+							+ propFile);
+		}
+
+		Properties props = new Properties();
+		props.load(new FileInputStream(propFile));
+
+		asdcAddress = props.getProperty("org.openecomp.sdnc.uebclient.asdc-address");
+		consumerGroup = props.getProperty("org.openecomp.sdnc.uebclient.consumer-group");
+		consumerID = props.getProperty("org.openecomp.sdnc.uebclient.consumer-id");
+		environmentName = props.getProperty("org.openecomp.sdnc.uebclient.environment-name");
+		password = props.getProperty("org.openecomp.sdnc.uebclient.password");
+		user = props.getProperty("org.openecomp.sdnc.uebclient.user");
+
+		sdncUser = props.getProperty("org.openecomp.sdnc.uebclient.sdnc-user");
+		sdncPasswd = props.getProperty("org.openecomp.sdnc.uebclient.sdnc-passwd");
+		asdcApiBaseUrl = props.getProperty("org.openecomp.sdnc.uebclient.asdc-api-base-url");
+		asdcApiNamespace = props.getProperty("org.openecomp.sdnc.uebclient.asdc-api-namespace");
+
+		incomingDir = props.getProperty("org.openecomp.sdnc.uebclient.spool.incoming");
+		archiveDir = props.getProperty("org.openecomp.sdnc.uebclient.spool.archive");
+		overrideFile = props.getProperty("org.openecomp.sdnc.uebclient.override-file");
+
+		String curval = props.getProperty("org.openecomp.sdnc.uebclient.polling-interval");
+		if ((curval != null) && (curval.length() > 0)) {
+			try {
+				pollingInterval = Integer.parseInt(curval);
+			} catch (Exception e) {
+				LOG.warn("Illegal value for org.openecomp.sdnc.uebclient.polling-interval ("+curval+")");
+			}
+		}
+
+		curval = props.getProperty("org.openecomp.sdnc.uebclient.polling-timeout");
+		if ((curval != null) && (curval.length() > 0)) {
+			try {
+				pollingTimeout = Integer.parseInt(curval);
+			} catch (Exception e) {
+				LOG.warn("Illegal value for org.openecomp.sdnc.uebclient.polling-timeout ("+curval+")");
+			}
+		}
+
+		curval = props.getProperty("org.openecomp.sdnc.uebclient.relevant-artifact-types");
+		if ((curval != null) && (curval.length() > 0)) {
+			String[] artifactTypes = curval.split(",");
+
+			relevantArtifactTypes = new LinkedList<String>();
+
+			for (int i = 0 ; i < artifactTypes.length ; i++) {
+				try {
+					if (ArtifactTypeEnum.valueOf(artifactTypes[i]) != null) {
+							relevantArtifactTypes.add(artifactTypes[i]);
+					} else {
+						LOG.warn("Skipping unrecognized artifact type "+artifactTypes[i]);
+					}
+				} catch (Exception e) {
+
+					LOG.warn("Caught exception validating artifact type "+artifactTypes[i], e);
+				}
+
+			}
+
+		}
+
+		curval = props.getProperty("org.openecomp.sdnc.uebclient.activate-server-tls-auth", "false");
+		activateServerTLSAuth = "true".equalsIgnoreCase(curval);
+		keyStorePath = props.getProperty("org.openecomp.sdnc.uebclient.keystore-path");
+		keyStorePassword = props.getProperty("org.openecomp.sdnc.uebclient.keystore-password");
+		xsltPathList = props.getProperty("org.openecomp.sdnc.uebclient.xslt-path-list");
+
+
+
+	}
+
+	@Override
+	public String getAsdcAddress() {
+		return asdcAddress;
+	}
+
+	@Override
+	public String getConsumerGroup() {
+		return consumerGroup;
+	}
+
+	@Override
+	public String getConsumerID() {
+		return consumerID;
+	}
+
+	@Override
+	public String getEnvironmentName() {
+		return environmentName;
+	}
+
+	@Override
+	public String getPassword() {
+		return password;
+	}
+
+	@Override
+	public int getPollingInterval() {
+		return pollingInterval;
+	}
+
+	@Override
+	public int getPollingTimeout() {
+		return pollingTimeout;
+	}
+
+	@Override
+	public List<String> getRelevantArtifactTypes() {
+		return relevantArtifactTypes;
+	}
+
+	@Override
+	public String getUser() {
+		return user;
+	}
+
+
+	public String getSdncUser() {
+		return sdncUser;
+	}
+
+	public String getSdncPasswd() {
+		return sdncPasswd;
+	}
+
+	public String getAsdcApiBaseUrl() {
+		return asdcApiBaseUrl;
+	}
+
+	@Override
+	public boolean activateServerTLSAuth() {
+		return activateServerTLSAuth;
+	}
+
+	@Override
+	public String getKeyStorePassword() {
+		return keyStorePassword;
+	}
+
+	@Override
+	public String getKeyStorePath() {
+		return keyStorePath;
+	}
+
+	public String getIncomingDir() {
+		return incomingDir;
+	}
+
+	public String getArchiveDir() {
+		return archiveDir;
+	}
+
+
+}
diff --git a/ueb-listener/src/main/resources/log4j.properties b/ueb-listener/src/main/resources/log4j.properties
new file mode 100644
index 00000000..274f2d45
--- /dev/null
+++ b/ueb-listener/src/main/resources/log4j.properties
@@ -0,0 +1,37 @@
+###
+# ============LICENSE_START=======================================================
+# openECOMP : SDN-C
+# ================================================================================
+# 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=========================================================
+###
+
+log4j.rootCategory=INFO,CONSOLE,LOGFILE
+
+# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
+log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
+log4j.appender.CONSOLE.Threshold=ERROR
+log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
+log4j.appender.CONSOLE.layout.ConversionPattern=%p %d{yyyy-MM-dd HH:mm:ss.SSS Z} %c{1} - %m%n
+ 
+# LOGFILE is set to be a File appender using a PatternLayout.
+log4j.appender.LOGFILE=org.apache.log4j.RollingFileAppender
+log4j.appender.LOGFILE.File=/opt/app/ueb-listener/logs/ueb-listener.log
+log4j.appender.LOGFILE.Append=true
+log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
+log4j.appender.LOGFILE.layout.ConversionPattern=%p %d{yyyy-MM-dd HH:mm:ss.SSS Z} %c{1} - %m%n
+log4j.appender.LOGFILE.MaxFileSize=10MB
+log4j.appender.LOGFILE.MaxBackupIndex=10
diff --git a/ueb-listener/src/main/resources/normalizeTagNames.xslt b/ueb-listener/src/main/resources/normalizeTagNames.xslt
new file mode 100755
index 00000000..6594ccfa
--- /dev/null
+++ b/ueb-listener/src/main/resources/normalizeTagNames.xslt
@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="utf-8"?>
+<xsl:stylesheet version="1.0"
+    xmlns:xsl="http://www.w3.org/1999/XSL/Transform">
+    <xsl:output method="xml" indent="yes" omit-xml-declaration="yes"/>
+    <xsl:template match="@*|node()">
+        <xsl:copy>
+            <xsl:apply-templates select="@*|node()" />
+        </xsl:copy>
+    </xsl:template>
+
+    <xsl:template match="vf-license-model/feature-group-list/feature-group/entitlement-pool-list/entitlement-pool/entitlement-metric/value/text()[.='# of software instances']">num of software instances</xsl:template>
+    <xsl:template match="vf-license-model/feature-group-list/feature-group/entitlement-pool-list/entitlement-pool/firstClassCitizenId"/>
+</xsl:stylesheet>
+
diff --git a/ueb-listener/src/main/resources/removeNs.xslt b/ueb-listener/src/main/resources/removeNs.xslt
new file mode 100755
index 00000000..7aa927b1
--- /dev/null
+++ b/ueb-listener/src/main/resources/removeNs.xslt
@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="utf-8"?>
+<xsl:stylesheet version="1.0"
+    xmlns:xsl="http://www.w3.org/1999/XSL/Transform">
+    <xsl:output method="xml" indent="yes" omit-xml-declaration="yes"/>
+
+    <xsl:template match="*">
+        <xsl:element name="{local-name(.)}">
+            <xsl:apply-templates select="@* | node()" />
+        </xsl:element>
+    </xsl:template>
+    <xsl:template match="@*">
+        <xsl:attribute name="{local-name(.)}">
+      <xsl:value-of select="." />
+    </xsl:attribute>
+    </xsl:template>
+</xsl:stylesheet>
\ No newline at end of file
diff --git a/ueb-listener/src/site/apt/index.apt b/ueb-listener/src/site/apt/index.apt
new file mode 100644
index 00000000..fb2cb293
--- /dev/null
+++ b/ueb-listener/src/site/apt/index.apt
@@ -0,0 +1,46 @@
+~~~
+~~ ============LICENSE_START=======================================================
+~~ openECOMP : SDN-C
+~~ ================================================================================
+~~ 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=========================================================
+~~~
+
+      ---
+      UEB Listener
+      ---
+
+
+UEB Listener
+
+    The UEB Listener is a daemon that listens for notifications from SDC, posted to UEB (Universal Event Bus).
+    On receipt of an event, the UEB listener downloads any artifacts posted and examines them to determine if
+    the format (the outer XML tag) matches a supported format.  If so, it posts the file to the ASDC-API REST
+    API in order to update the SDN-C database.
+
+File Locations
+
+    * Root directory : /opt/app/ueb-listener
+
+    * Log files : /opt/app/ueb-listener/logs
+
+    * Incoming files to be processed : /opt/app/ueb-listener/spool/asdc/incoming
+
+    * Files already processed : /opt/app/ueb-listener/spool/asdc/archive
+
+
+
+
diff --git a/ueb-listener/src/site/site.xml b/ueb-listener/src/site/site.xml
new file mode 100644
index 00000000..1d4e73ff
--- /dev/null
+++ b/ueb-listener/src/site/site.xml
@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="ISO-8859-1"?>
+<!--
+  ============LICENSE_START=======================================================
+  openECOMP : SDN-C
+  ================================================================================
+  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=========================================================
+  -->
+
+<project>
+
+  <body>
+    <menu ref="modules"/>
+
+    <menu ref="reports"/>
+
+  </body>
+</project>