[ONAP-rebase] Rebase as 1.1.0-SNAPSHOT

Consolidate into a single maven project; no more separate model and client jars.

Change-Id: Ibbba982250b74c0dfd09ee1c65c0fb6c158dd632
Signed-off-by: Christopher Lott <cl778h@att.com>
Signed-off-by: Christopher Lott (cl778h) <clott@research.att.com>

9 files changed, 0 insertions, 2265 deletions

diff --git a/dcae_dmaapbc_client/.gitignore b/dcae_dmaapbc_client/.gitignore
deleted file mode 100644
index d4111ff..0000000
--- a/dcae_dmaapbc_client/.gitignore
+++ /dev/null
@@ -1,2 +0,0 @@
-/.settings/
-/target/
diff --git a/dcae_dmaapbc_client/README.md b/dcae_dmaapbc_client/README.md
deleted file mode 100644
index a803c4a..0000000
--- a/dcae_dmaapbc_client/README.md
+++ /dev/null
@@ -1,17 +0,0 @@
-
-### DCAE DMaaP Bus Controller API Client
-
-Provides a Java client for using the DCAE DMaaP Bus Controller API via REST.
-Implements all API methods.
-Initial motivation was to support the Bus Controller webapp developed in 1610.
-
-#### Build Instructions
-
-This project is organized as a mvn project for a jar package.
-
-#### Contact
-
-Chris Lott, cl778h
-
-#### Release Notes
-Version 1.0
\ No newline at end of file
diff --git a/dcae_dmaapbc_client/pom.xml b/dcae_dmaapbc_client/pom.xml
deleted file mode 100644
index b347ac1..0000000
--- a/dcae_dmaapbc_client/pom.xml
+++ /dev/null
@@ -1,209 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>
-
-	<!-- repository key for AT&T maven central -->
-	<groupId>org.openecomp.ui.dmaapbc</groupId>
-	<artifactId>dmaap-bc-client</artifactId>
-	<version>1.1.0-SNAPSHOT</version>
-	<name>DCAE DMaaP Bus Controller REST Client</name>
-	<description>Java client for using the DMaaP Bus Controller API via REST.</description>
-	<scm>
-		<url>https://gitlab/projects/ST_DBPA/repos/dcae_dmaapbc_client/browse</url>
-		<developerConnection>scm:git:ssh://git@gitlab/st_dbpa/dcae_dmaapbc_client.git</developerConnection>
-	</scm>
-
-	<properties>
-		<encoding>UTF-8</encoding>
-		<skiptests>true</skiptests>
-		<nexusproxy>https://nexus.onap.org</nexusproxy>
-		<snapshotNexusPath>/content/repositories/snapshots/</snapshotNexusPath>
-		<releaseNexusPath>/content/repositories/releases/</releaseNexusPath>
-		<stagingNexusPath>/content/repositories/staging/</stagingNexusPath>
-	</properties>
-
-	<repositories>
-		<repository>
-			<!-- Releases repository has ECOMP release artifacts -->
-			<id>ecomp-releases</id>
-			<name>OpenECOMP - Release Repository</name>
-			<url>${nexusproxy}/${releaseNexusPath}</url>
-		</repository>
-		<repository>
-			<!-- Snapshots repository has ECOMP snapshot artifacts -->
-			<id>ecomp-snapshots</id>
-			<name>OpenECOMP - Snapshot Repository</name>
-			<url>${nexusproxy}/${snapshotNexusPath}</url>
-		</repository>
-	</repositories>
-
-	<profiles>
-		<!-- disable doclint, a new feature in Java 8, when generating javadoc -->
-		<profile>
-			<id>doclint-java8-disable</id>
-			<activation>
-				<jdk>[1.8,)</jdk>
-			</activation>
-			<build>
-				<plugins>
-					<plugin>
-						<groupId>org.apache.maven.plugins</groupId>
-						<artifactId>maven-javadoc-plugin</artifactId>
-						<version>2.10.4</version>
-						<configuration>
-							<additionalparam>-Xdoclint:none</additionalparam>
-						</configuration>
-					</plugin>
-				</plugins>
-			</build>
-		</profile>
-	</profiles>
-
-	<build>
-		<plugins>
-			<plugin>
-				<groupId>org.sonatype.plugins</groupId>
-				<artifactId>nexus-staging-maven-plugin</artifactId>
-				<version>1.6.7</version>
-				<extensions>true</extensions>
-				<configuration>
-					<nexusUrl>${nexusproxy}</nexusUrl>
-					<stagingProfileId>176c31dfe190a</stagingProfileId>
-					<serverId>ecomp-staging</serverId>
-				</configuration>
-			</plugin>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-scm-plugin</artifactId>
-				<version>1.8.1</version>
-				<configuration>
-					<connectionType>developerConnection</connectionType>
-					<scmVersionType>branch</scmVersionType>
-					<scmVersion>master</scmVersion>
-				</configuration>
-			</plugin>
-			<!-- Compile to Java 1.8 class output format -->
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-compiler-plugin</artifactId>
-				<version>3.1</version>
-				<configuration>
-					<source>1.8</source>
-					<target>1.8</target>
-				</configuration>
-			</plugin>
-			<!-- do not distribute the logback.xml file -->
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-jar-plugin</artifactId>
-				<version>3.0.2</version>
-				<configuration>
-					<excludes>
-						<exclude>**/logback.xml</exclude>
-					</excludes>
-				</configuration>
-			</plugin>
-			<!-- Generate javadoc jar; see profile for Java 8 -->
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-javadoc-plugin</artifactId>
-				<version>2.10.3</version>
-				<executions>
-					<execution>
-						<id>attach-javadocs</id>
-						<goals>
-							<goal>jar</goal>
-						</goals>
-					</execution>
-				</executions>
-			</plugin>
-			<!-- Generate source jar -->
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-source-plugin</artifactId>
-				<version>3.0.0</version>
-				<executions>
-					<execution>
-						<id>attach-sources</id>
-						<goals>
-							<goal>jar</goal>
-						</goals>
-					</execution>
-				</executions>
-			</plugin>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-surefire-plugin</artifactId>
-				<version>2.19.1</version>
-				<configuration>
-					<skipTests>${skiptests}</skipTests>
-				</configuration>
-			</plugin>
-			<!-- older versions are very buggy -->
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-release-plugin</artifactId>
-				<version>2.5.3</version>
-			</plugin>
-		</plugins>
-	</build>
-
-	<dependencies>
-		<!-- model classes -->
-		<dependency>
-			<groupId>org.openecomp.ui.dmaapbc</groupId>
-			<artifactId>dmaap-bc-model</artifactId>
-			<version>1.1.0-SNAPSHOT</version>
-		</dependency>
-		<dependency>
-			<groupId>ch.qos.logback</groupId>
-			<artifactId>logback-classic</artifactId>
-			<version>1.1.1</version>
-		</dependency>
-		<dependency>
-			<groupId>com.fasterxml.jackson.core</groupId>
-			<artifactId>jackson-core</artifactId>
-			<version>2.6.3</version>
-		</dependency>
-		<dependency>
-			<groupId>com.fasterxml.jackson.core</groupId>
-			<artifactId>jackson-databind</artifactId>
-			<version>2.6.3</version>
-		</dependency>
-		<dependency>
-			<groupId>org.apache.httpcomponents</groupId>
-			<artifactId>httpclient</artifactId>
-			<version>4.5</version>
-		</dependency>
-		<dependency>
-			<groupId>org.slf4j</groupId>
-			<artifactId>slf4j-api</artifactId>
-			<version>1.7.21</version>
-		</dependency>
-		<dependency>
-			<groupId>org.slf4j</groupId>
-			<artifactId>jcl-over-slf4j</artifactId>
-			<version>1.7.21</version>
-		</dependency>
-		<dependency>
-			<groupId>junit</groupId>
-			<artifactId>junit</artifactId>
-			<version>4.12</version>
-		</dependency>
-	</dependencies>
-
-	<distributionManagement>
-		<repository>
-			<id>ecomp-releases</id>
-			<name>OpenECOMP - Release Repository</name>
-			<url>${nexusproxy}/${releaseNexusPath}</url>
-		</repository>
-		<snapshotRepository>
-			<id>ecomp-snapshots</id>
-			<name>OpenECOMP - Snapshot Repository</name>
-			<url>${nexusproxy}/${snapshotNexusPath}</url>
-		</snapshotRepository>
-	</distributionManagement>
-
-</project>
diff --git a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/DmaapBcRestClient.java b/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/DmaapBcRestClient.java
deleted file mode 100644
index f8a58e9..0000000
--- a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/DmaapBcRestClient.java
+++ /dev/null
@@ -1,1480 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller REST Client
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * 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.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaap.bcapi.client;
-
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.http.client.utils.URIBuilder;
-import org.openecomp.dcae.dmaapbc.model.DR_Node;
-import org.openecomp.dcae.dmaapbc.model.DR_Pub;
-import org.openecomp.dcae.dmaapbc.model.DR_Sub;
-import org.openecomp.dcae.dmaapbc.model.DcaeLocation;
-import org.openecomp.dcae.dmaapbc.model.Dmaap;
-import org.openecomp.dcae.dmaapbc.model.DmaapObject;
-import org.openecomp.dcae.dmaapbc.model.ErrorResponse;
-import org.openecomp.dcae.dmaapbc.model.Feed;
-import org.openecomp.dcae.dmaapbc.model.MR_Client;
-import org.openecomp.dcae.dmaapbc.model.MR_Cluster;
-import org.openecomp.dcae.dmaapbc.model.Topic;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-/**
- * Provides methods to communicate with the DMaaP Bus Controller REST API. This
- * hides all JSON; instead it accepts and returns Java objects.
- */
-public class DmaapBcRestClient extends SimpleRestClientBase {
-
-	private static Logger logger = LoggerFactory.getLogger(DmaapBcRestClient.class);
-
-	// Omit leading and trailing slashes here
-	private static final String DCAELOCATIONS = "dcaeLocations";
-	private static final String DMAAP = "dmaap";
-	private static final String DR_NODES = "dr_nodes";
-	private static final String DR_PUBS = "dr_pubs";
-	private static final String DR_SUBS = "dr_subs";
-	private static final String FEEDS = "feeds";
-	private static final String TOPICS = "topics";
-	private static final String MR_CLUSTERS = "mr_clusters";
-	private static final String MR_CLIENTS = "mr_clients";
-
-	/**
-	 * Reusable JSON (de)serializer
-	 */
-	private final ObjectMapper mapper;
-
-	/**
-	 * URL of the DMAAP REST endpoint
-	 */
-	private final String dmaapRestUrl;
-
-	/**
-	 * Constructor that configures the client for the specified endpoint using
-	 * no authentication.
-	 * 
-	 * @param dmaapRestUrl
-	 */
-	public DmaapBcRestClient(final String dmaapRestUrl) {
-		super();
-		this.dmaapRestUrl = dmaapRestUrl;
-		this.mapper = new ObjectMapper();
-		// Don't serialize null-value fields in objects
-		this.mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
-	}
-
-	/**
-	 * Constructor that onfigures the client for the specified endpoint using
-	 * the specified username and password for basic HTTP authentication.
-	 * 
-	 * @param dmaapRestUrl
-	 * @param username
-	 * @param password
-	 */
-	public DmaapBcRestClient(final String dmaapRestUrl, final String username, final String password) {
-		super(username, password);
-		this.dmaapRestUrl = dmaapRestUrl;
-		this.mapper = new ObjectMapper();
-		// Don't serialize null-value fields in objects
-		this.mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
-	}
-
-	/**
-	 * Configures the behavior of the JSON deserializer used to build business
-	 * objects (e.g., a Feed) from REST responses.
-	 * 
-	 * @param failOnUnknownProperties
-	 *            If true, rejects JSON responses with unexpected fields
-	 *            (default behavior); if false, ignores unexpected fields.
-	 */
-	public void setFailOnUnknownProperties(boolean failOnUnknownProperties) {
-		mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, failOnUnknownProperties);
-	}
-
-	/**
-	 * Gets the DMaaP endpoint URL that is used by methods in this class.
-	 * 
-	 * @return dmaapEndpointUrl
-	 */
-	public String getDmaapRestUrl() {
-		return this.dmaapRestUrl;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of DCAE locations.
-	 * 
-	 * @return List of DmaapObject: list contains DcaeLocation object(s) on
-	 *         success; a single ErrorResponse object if the remote site rejects
-	 *         the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getDcaeLocations() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DCAELOCATIONS));
-		logger.debug("getDcaeLocations: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDcaeLocations: unexpected null response");
-
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<DcaeLocation>> typeRef = new TypeReference<List<DcaeLocation>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getDcaeLocations: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets the DCAE location with the specified name.
-	 * 
-	 * @param locName
-	 *            name of the location to get
-	 * @return DmaapObject: a DcaeLocation object on success; an ErrorResponse
-	 *         object if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getDcaeLocation(final String locName) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DCAELOCATIONS, locName));
-		logger.debug("getDcaeLocation: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDcaeLocation: unexpected null response");
-
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), DcaeLocation.class);
-		} catch (Exception ex) {
-			logger.debug("getDcaeLocation: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a DCAE location in DMaaP.
-	 * 
-	 * @param dcaeLoc
-	 * DcaeLocation to be created
-	 * @return Status and response: expect 200 and a DcaeLocation on success; a
-	 *         code and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postDcaeLocation(DcaeLocation dcaeLoc) throws Exception {
-		String jsonBody = mapper.writeValueAsString(dcaeLoc);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(DCAELOCATIONS), jsonBody);
-		if (hsr == null)
-			throw new Exception("postDcaeLocation: unexpected null response");
-		logger.debug("postDcaeLocation: resp is {}", hsr);
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postDcaeLocation: null response body");
-			return response;
-		}
-		try {
-			DcaeLocation resp = mapper.readValue(hsr.getResponseString(), DcaeLocation.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDcaeLocation: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the DCAE location with the specified name.
-	 * 
-	 * @param locName
-	 *            Name of the location to delete
-	 * @return Status and response: expect 204 and a DcaeLocation on success; a
-	 *         code and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteDcaeLocation(final String locName) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(DCAELOCATIONS, locName));
-		logger.debug("deleteDcaeLocation: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteDcaeLocation: unexpected null response");
-		// Returns a loc on success, error message string on error.
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteDcaeLocation: null response body");
-			return response;
-		}
-		try {
-			DcaeLocation resp = mapper.readValue(hsr.getResponseString(), DcaeLocation.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteDcaeLocation: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-	
-	/**
-	 * Updates a DCAE location.
-	 * 
-	 * @param dcaeLoc
-	 *            DCAE Location to be updated
-	 * @return Status and response; expect 200 and a DcaeLocation on success, a
-	 *         string error on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putDcaeLocation(DcaeLocation dcaeLoc) throws Exception {
-		String jsonBody = mapper.writeValueAsString(dcaeLoc);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(DCAELOCATIONS, dcaeLoc.getDcaeLocationName()), jsonBody);
-		logger.debug("putDcaeLocation: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putDcaeLocation: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putDcaeLocation: null response body");
-			return response;
-		}
-		try {
-			DcaeLocation resp = mapper.readValue(hsr.getResponseString(), DcaeLocation.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putDcaeLocation: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets the DMAAP instance for this DCAE deployment.
-	 * 
-	 * @return DmaapObject: a Dmaap object on success; an ErrorResponse object
-	 *         if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getDmaap() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DMAAP));
-		logger.debug("getDmaap: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDmaap: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), Dmaap.class);
-		} catch (Exception ex) {
-			logger.debug("getDmaap: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a new DMaaP set system wide configuration settings for the
-	 * dcaeEnvironment
-	 * 
-	 * @param dmaap
-	 * @return Status and response: expect 200 and a Dmaap on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postDmaap(Dmaap dmaap) throws Exception {
-		String jsonBody = mapper.writeValueAsString(dmaap);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(DMAAP), jsonBody);
-		if (hsr == null)
-			throw new Exception("postDmaap: unexpected null response");
-		logger.debug("postDmaap: resp is {}", hsr);
-		// Returns ? on success, error message string on error.
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postDmaap: null response body");
-			return response;
-		}
-		try {
-			Dmaap resp = mapper.readValue(hsr.getResponseString(), Dmaap.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDmaap: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates DMaaP system wide configuration settings for the dcaeEnvironment.
-	 * 
-	 * @param dmaap
-	 * @return Status and response; expect 200 and a DR_Pub on success; a code
-	 *         and and ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putDmaap(Dmaap dmaap) throws Exception {
-		String jsonBody = mapper.writeValueAsString(dmaap);
-		// Oddly, this PUT has no ID parameter in the URL
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(DMAAP), jsonBody);
-		if (hsr == null)
-			throw new Exception("putDmaap: unexpected null response");
-		logger.debug("putDmaap: resp is {}", hsr);
-		// Returns ? on success, error message string on error.
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putDmaap: null response body");
-			return response;
-		}
-		try {
-			Dmaap resp = mapper.readValue(hsr.getResponseString(), Dmaap.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putDmaap: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	// NO DELETE_DMAAP METHOD
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of data router nodes.
-	 * 
-	 * @return List of DmaapObject: list contains DR_Node object(s) on success;
-	 *         a single ErrorResponse object if the remote site rejects the
-	 *         request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getDRNodes() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_NODES));
-		logger.debug("getDRNodes: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRNodes: unexpected null response");
-
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<DR_Node>> typeRef = new TypeReference<List<DR_Node>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getDRNodes: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets a data router node with the specified ID.
-	 * 
-	 * @param fqdn
-	 *            Name of the node to get
-	 * @return DmaapObject: a DR_Node object on success; an ErrorResponse object
-	 *         if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getDRNode(final String fqdn) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_NODES, fqdn));
-		logger.debug("getDRNode: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRNode: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), DR_Node.class);
-		} catch (Exception ex) {
-			logger.debug("getDRNode: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a data router node.
-	 * 
-	 * @param drNode
-	 *            Node to be created
-	 * @return Status and response: expect 200 and a DR_Node on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postDRNode(DR_Node drNode) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drNode);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(DR_NODES), jsonBody);
-		logger.debug("postDRNode: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postDRNode: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postDRNode: null response body");
-			return response;
-		}
-		try {
-			DR_Node resp = mapper.readValue(hsr.getResponseString(), DR_Node.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDRNode: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a data router node.
-	 * 
-	 * @param drNode
-	 *            Node to be updated
-	 * @return Status and response: expect 200 and a DR_Node on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putDRNode(DR_Node drNode) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drNode);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(DR_NODES, drNode.getFqdn()), jsonBody);
-		logger.debug("putDRNode: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putDRNode: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putDRNode: null response body");
-			return response;
-		}
-		try {
-			DR_Node resp = mapper.readValue(hsr.getResponseString(), DR_Node.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDRNode: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the data router node with the specified FQDN.
-	 * 
-	 * @param fqdn
-	 *            Name of the node to delete
-	 * @return Status and response: expect 204 and a null on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteDRNode(final String fqdn) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(DR_NODES, fqdn));
-		logger.debug("deleteDRNode: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteDRNode: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteDRNode: null response body");
-			return response;
-		}
-		try {
-			DR_Node resp = mapper.readValue(hsr.getResponseString(), DR_Node.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteDRNode: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of data router publishers.
-	 * 
-	 * @return List of DmaapObject: list contains DR_Pub object(s) on success; a
-	 *         single ErrorResponse object if the remote site rejects the
-	 *         request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getDRPubs() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_PUBS));
-		logger.debug("getDRPubs: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRPubs: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<DR_Pub>> typeRef = new TypeReference<List<DR_Pub>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getDRPubs: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets a data router publisher with the specified ID.
-	 * 
-	 * @param pubId
-	 *            ID of the publisher to get
-	 * @return DmaapObject: a DR_Pub object on success; an ErrorResponse object
-	 *         if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getDRPub(final String pubId) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_PUBS, pubId));
-		logger.debug("getDRPub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRPub: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), DR_Pub.class);
-		} catch (Exception ex) {
-			logger.debug("getDRPub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a data router publisher.
-	 * 
-	 * @param drPub
-	 * @return Status and response: expect 200 and a DR_Pub on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postDRPub(DR_Pub drPub) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drPub);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(DR_PUBS), jsonBody);
-		logger.debug("postDRPub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postDRPub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postDRPub: null response body");
-			return response;
-		}
-		try {
-			DR_Pub resp = mapper.readValue(hsr.getResponseString(), DR_Pub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDRPub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a data router publisher.
-	 * 
-	 * @param drPub
-	 *            Publisher to be updated
-	 * @return Status and response: expect 200 and a DR_Pub on success, a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putDRPub(DR_Pub drPub) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drPub);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(DR_PUBS, drPub.getPubId()), jsonBody);
-		logger.debug("putDRPub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putDRPub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putDRPub: null response body");
-			return response;
-		}
-		try {
-			DR_Pub resp = mapper.readValue(hsr.getResponseString(), DR_Pub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDRPub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the data router publisher with the specified ID.
-	 * 
-	 * @param pubId
-	 *            ID of the publisher to delete
-	 * @return Status and response: expect 204 and a null on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteDRPub(final String pubId) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(DR_PUBS, pubId));
-		logger.debug("deleteDRPub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteDRPub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteDRPub: null response body");
-			return response;
-		}
-		try {
-			DR_Pub resp = mapper.readValue(hsr.getResponseString(), DR_Pub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteDRPub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of data router subscribers.
-	 * 
-	 * @return List of DmaapObject: list contains DR_Sub object(s) on success; a
-	 *         single ErrorResponse object if the remote site rejects the
-	 *         request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getDRSubs() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_SUBS));
-		logger.debug("getDRSubs: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRSubs: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<DR_Sub>> typeRef = new TypeReference<List<DR_Sub>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getDRSubs: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets a data router subscriber with the specified ID.
-	 * 
-	 * @param subId
-	 *            ID of the subscriber to get
-	 * @return DmaapObject: a DR_Sub object on success; an ErrorResponse object
-	 *         if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getDRSub(final String subId) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(DR_SUBS, subId));
-		logger.debug("getDRPub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getDRSub: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), DR_Sub.class);
-		} catch (Exception ex) {
-			logger.debug("getDRSub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a data router subscriber.
-	 * 
-	 * @param drSub
-	 * @return Status and response: expect 200 and a DR_Sub on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postDRSub(DR_Sub drSub) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drSub);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(DR_SUBS), jsonBody);
-		logger.debug("postDRSub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postDRSub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postDRSub: null response body");
-			return response;
-		}
-		try {
-			DR_Sub resp = mapper.readValue(hsr.getResponseString(), DR_Sub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postDRSub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a data router subscriber.
-	 * 
-	 * @param drSub
-	 *            Subscriber to be updated
-	 * @return Status and response; expect 200 and a DR_Sub on success, a string
-	 *         error on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putDRSub(DR_Sub drSub) throws Exception {
-		String jsonBody = mapper.writeValueAsString(drSub);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(DR_SUBS, drSub.getSubId()), jsonBody);
-		logger.debug("putDRSub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putDRSub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putDRSub: null response body");
-			return response;
-		}
-		try {
-			DR_Sub resp = mapper.readValue(hsr.getResponseString(), DR_Sub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putDRSub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the data router subscriber with the specified ID.
-	 * 
-	 * @param subId
-	 *            ID of the subscriber to delete
-	 * @return Status and response: expect 204 and a null on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteDRSub(final String subId) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(DR_SUBS, subId));
-		logger.debug("deleteDRSub: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteDRSub: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteDRSub: null response body");
-			return response;
-		}
-		try {
-			DR_Sub resp = mapper.readValue(hsr.getResponseString(), DR_Sub.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteDRSub: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of data router feeds.
-	 * 
-	 * @return List of DmaapObject: list contains DcaeLocation object(s) on
-	 *         success; a single ErrorResponse object if the remote site rejects
-	 *         the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getFeeds() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(FEEDS));
-		logger.debug("getFeeds: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getFeeds: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<Feed>> typeRef = new TypeReference<List<Feed>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getFeeds: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets a data router feed with the specified ID.
-	 * 
-	 * @param feedId
-	 *            ID of the feed to get
-	 * @return DmaapObject: a Feed object on success; an ErrorResponse object if
-	 *         the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getFeed(final String feedId) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(FEEDS, feedId));
-		logger.debug("getFeed: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getFeed: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), Feed.class);
-		} catch (Exception ex) {
-			logger.debug("getFeed: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a feed and adds any specified pubs and subs.
-	 * 
-	 * @param feed
-	 * @return Status and response: expect 200 and a Feed on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postFeed(Feed feed) throws Exception {
-		String jsonBody = mapper.writeValueAsString(feed);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(FEEDS), jsonBody);
-		logger.debug("postFeed: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postFeed: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postFeed: null response body");
-			return response;
-		}
-		try {
-			Feed resp = mapper.readValue(hsr.getResponseString(), Feed.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postFeed: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a data router feed.
-	 * 
-	 * @param feed
-	 *            Feed to be updated
-	 * @return Status and response: expect 200 and a Feed on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putFeed(Feed feed) throws Exception {
-		String jsonBody = mapper.writeValueAsString(feed);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(FEEDS, feed.getFeedId()), jsonBody);
-		logger.debug("putFeed: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putFeed: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putFeed: null response body");
-			return response;
-		}
-		try {
-			Feed resp = mapper.readValue(hsr.getResponseString(), Feed.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putFeed: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the data router feed with the specified ID.
-	 * 
-	 * @param feedId
-	 *            ID of the feed to delete
-	 * @return Status and response: expect 204 and a null on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteFeed(final String feedId) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(FEEDS, feedId));
-		logger.debug("deleteFeed: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteFeed: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteFeed: null response body");
-			return response;
-		}
-		try {
-			Feed resp = mapper.readValue(hsr.getResponseString(), Feed.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteFeed: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of message router topics.
-	 * 
-	 * @return List of DmaapObject: list contains Topic object(s) on success; a
-	 *         single ErrorResponse object if the remote site rejects the
-	 *         request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getTopics() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(TOPICS));
-		logger.debug("getTopics: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getTopics: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<Topic>> typeRef = new TypeReference<List<Topic>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getTopics: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets the message router topic with the specified FQTN.
-	 * 
-	 * @param fqtn
-	 *            Fully qualified topic name
-	 * @return DmaapObject: a Topic object on success; an ErrorResponse object
-	 *         if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getTopic(final String fqtn) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(TOPICS, fqtn));
-		logger.debug("getTopic: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getTopic: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), Topic.class);
-		} catch (Exception ex) {
-			logger.debug("getTopic: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a topic and grants appropriate permissions to specified pubs and
-	 * subs.
-	 * 
-	 * @param topic
-	 * @return Status and response: expect 200 and a Topic on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postTopic(Topic topic) throws Exception {
-		String jsonBody = mapper.writeValueAsString(topic);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(TOPICS), jsonBody);
-		logger.debug("postTopic: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postTopic: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postTopic: null response body");
-			return response;
-		}
-		try {
-			Topic resp = mapper.readValue(hsr.getResponseString(), Topic.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postTopic: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the message router topic with the specified FQTN.
-	 * 
-	 * @param fqtn
-	 *            Fully qualified topic name to delete
-	 * @return Status and response: expect 204 and a null on success; a code and
-	 *         an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteTopic(final String fqtn) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(TOPICS, fqtn));
-		logger.debug("deleteTopic: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteTopic: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteTopic: null response body");
-			return response;
-		}
-		try {
-			Topic resp = mapper.readValue(hsr.getResponseString(), Topic.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteTopic: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of message router clients.
-	 * 
-	 * @return List of DmaapObject: list contains MR_Client object(s) on
-	 *         success; a single ErrorResponse object if the remote site rejects
-	 *         the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getMRClients() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(MR_CLIENTS));
-		logger.debug("getMRClients: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getMRClients: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<MR_Client>> typeRef = new TypeReference<List<MR_Client>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getMRClients: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets the message router client with the specified ID.
-	 * 
-	 * @param mrClientId
-	 *            ID of the client to get
-	 * @return DmaapObject: a MR_Client object on success; an ErrorResponse
-	 *         object if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getMRClient(final String mrClientId) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(MR_CLIENTS, mrClientId));
-		logger.debug("getMRClient: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getMRClient: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), MR_Client.class);
-		} catch (Exception ex) {
-			logger.debug("getMRClient: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a message router client.
-	 * 
-	 * @param mrClient
-	 * @return Status and response: expect 200 and a MR_Client on success; a
-	 *         code and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postMRClient(MR_Client mrClient) throws Exception {
-		String jsonBody = mapper.writeValueAsString(mrClient);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(MR_CLIENTS), jsonBody);
-		logger.debug("postMRClient: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postMRClient: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postMRClient: null response body");
-			return response;
-		}
-		try {
-			MR_Client resp = mapper.readValue(hsr.getResponseString(), MR_Client.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postMRClient: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a message router client.
-	 * 
-	 * @param mrClient
-	 *            client to be updated
-	 * @return Status and response; expect 200 and a MR_Client on success, a
-	 *         string error on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putMRClient(MR_Client mrClient) throws Exception {
-		String jsonBody = mapper.writeValueAsString(mrClient);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(MR_CLIENTS, mrClient.getMrClientId()), jsonBody);
-		logger.debug("putMRClient: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putMRClient: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putMRClient: null response body");
-			return response;
-		}
-		try {
-			MR_Client resp = mapper.readValue(hsr.getResponseString(), MR_Client.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putMRClient: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the message router client with the specified ID.
-	 * 
-	 * @param mrClientId
-	 *            ID of the client to delete
-	 * @return Status and response; expect 204 and a null on success, a string
-	 *         error on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteMRClient(final String mrClientId) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(MR_CLIENTS, mrClientId));
-		logger.debug("deleteMRClient: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("deleteMRClient: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteMRClient: null response body");
-			return response;
-		}
-		try {
-			MR_Client resp = mapper.readValue(hsr.getResponseString(), MR_Client.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteMRClient: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Gets a list of message router clusters.
-	 * 
-	 * @return List of DmaapObject: list contains MR_Cluster object(s) on
-	 *         success; a single ErrorResponse object if the remote site rejects
-	 *         the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public List<DmaapObject> getMRClusters() throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(MR_CLUSTERS));
-		logger.debug("getMRClusters: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getMRClusters: unexpected null response");
-		List<DmaapObject> responseList = null;
-		try {
-			TypeReference<List<MR_Cluster>> typeRef = new TypeReference<List<MR_Cluster>>() {
-			};
-			responseList = mapper.readValue(hsr.getResponseString(), typeRef);
-		} catch (Exception ex) {
-			logger.debug("getDcaeLocations: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			responseList = new ArrayList<DmaapObject>();
-			responseList.add(errResp);
-		}
-		return responseList;
-	}
-
-	/**
-	 * Gets the message router cluster with the specified location name.
-	 * 
-	 * @param dcaeLocName
-	 *            name of the cluster to get
-	 * @return DmaapObject: a MR_Cluster object on success; an ErrorResponse
-	 *         object if the remote site rejects the request.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public DmaapObject getMRCluster(final String dcaeLocName) throws Exception {
-		HttpStatusAndResponse<String> hsr = getRestContent(buildDmaapUri(MR_CLUSTERS, dcaeLocName));
-		logger.debug("getMRCluster: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("getMRCluster: unexpected null response");
-		DmaapObject response = null;
-		try {
-			response = mapper.readValue(hsr.getResponseString(), MR_Cluster.class);
-		} catch (Exception ex) {
-			logger.debug("getMRCluster: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			response = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-		}
-		return response;
-	}
-
-	/**
-	 * Creates a message router cluster.
-	 * 
-	 * @param mrCluster
-	 * @return Status and response: expect 200 and a MR_Cluster on success; a
-	 *         code and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> postMRCluster(MR_Cluster mrCluster) throws Exception {
-		String jsonBody = mapper.writeValueAsString(mrCluster);
-		HttpStatusAndResponse<String> hsr = postRestContent(buildDmaapUri(MR_CLUSTERS), jsonBody);
-		logger.debug("postMRCluster: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("postMRCluster: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("postMRCluster: null response body");
-			return response;
-		}		
-		try {
-			MR_Cluster resp = mapper.readValue(hsr.getResponseString(), MR_Cluster.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("postMRCluster: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Updates a message router cluster.
-	 * 
-	 * @param mrCluster
-	 *            cluster to be updated
-	 * @return Status and response; expect 200 and a MR_Cluster on success, a
-	 *         string error on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> putMRCluster(MR_Cluster mrCluster) throws Exception {
-		String jsonBody = mapper.writeValueAsString(mrCluster);
-		HttpStatusAndResponse<String> hsr = putRestContent(buildDmaapUri(MR_CLUSTERS, mrCluster.getDcaeLocationName()), jsonBody);
-		logger.debug("putMRCluster: resp is {}", hsr);
-		if (hsr == null)
-			throw new Exception("putMRCluster: unexpected null response");
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("putMRCluster: null response body");
-			return response;
-		}		
-		try {
-			MR_Cluster resp = mapper.readValue(hsr.getResponseString(), MR_Cluster.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("putMRCluster: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/**
-	 * Deletes the message router cluster with the specified location name.
-	 * 
-	 * @param dcaeLocName
-	 *            Location name of the cluster to delete
-	 * @return Status and response: expect 204 and a null on success; a code
-	 *         and an ErrorResponse on failure.
-	 * @throws Exception
-	 *             if host cannot be reached, response cannot be parsed, etc.
-	 */
-	public HttpStatusAndResponse<Object> deleteMRCluster(final String dcaeLocName) throws Exception {
-		HttpStatusAndResponse<String> hsr = deleteRestContent(buildDmaapUri(MR_CLUSTERS, dcaeLocName));
-		if (hsr == null)
-			throw new Exception("deleteMRCluster: unexpected null response");
-		logger.debug("deleteMRCluster: resp is {}", hsr);
-		HttpStatusAndResponse<Object> response = new HttpStatusAndResponse<Object>(hsr.getStatusCode(), null);
-		if (hsr.getResponse() == null) {
-			logger.debug("deleteMRCluster: null response body");
-			return response;
-		}		
-		try {
-			MR_Cluster resp = mapper.readValue(hsr.getResponseString(), MR_Cluster.class);
-			response.setResponse(resp);
-		} catch (Exception ex) {
-			logger.debug("deleteMRCluster: trying to parse response as error: {}", ex.toString());
-			// If this parse fails, let the exception be thrown
-			ErrorResponse errResp = mapper.readValue(hsr.getResponseString(), ErrorResponse.class);
-			response.setResponse(errResp);
-		}
-		return response;
-	}
-
-	/////////////////////////////////////////////////////////////////////
-
-	/**
-	 * Builds the URI for the DMaaP REST endpoint using configuration and the
-	 * specified task and path parameter(s). Deals with extra or missing slashes
-	 * to allow for some flexibility in the config file.
-	 * 
-	 * @param requestPath
-	 *            Last part of endpoint path
-	 * @param pathParam
-	 *            Additional path parameters in order; ignored if null or empty
-	 * @return REST endpoint URI
-	 * @throws Exception
-	 *             if the RESAT URL property is not found
-	 */
-	private URI buildDmaapUri(String task, String... pathParam) throws Exception {
-		if (dmaapRestUrl == null || dmaapRestUrl.length() == 0)
-			throw new Exception("buildUrlPath: unconfigured, must set dmaapEndpointUrl");
-		StringBuilder sb = new StringBuilder();
-		// Clean the base of any trailing slashes
-		sb.append(trimSlashes(dmaapRestUrl));
-		sb.append('/');
-		// task is controlled in this file, don't clean it.
-		sb.append(task);
-		if (pathParam != null) {
-			for (String pp : pathParam) {
-				sb.append('/');
-				// path comes from the user, definitely clean it.
-				sb.append(trimSlashes(pp));
-			}
-		}
-		String urlPath = sb.toString();
-		URIBuilder uriBuilder = new URIBuilder(urlPath);
-		return uriBuilder.build();
-	}
-
-	/**
-	 * Strips the specified string of leading and trailing forward-slash
-	 * characters.
-	 * 
-	 * @param s
-	 *            String to trim
-	 * @return String without any leading or trailing '/' characters.
-	 */
-	private String trimSlashes(String s) {
-		while (s.length() > 0 && s.charAt(0) == '/')
-			s = s.substring(1, s.length());
-		while (s.length() > 0 && s.charAt(s.length() - 1) == '/')
-			s = s.substring(0, s.length() - 1);
-		return s;
-	}
-
-}
diff --git a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/HttpStatusAndResponse.java b/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/HttpStatusAndResponse.java
deleted file mode 100644
index 3b8e97e..0000000
--- a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/HttpStatusAndResponse.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller REST Client
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * 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.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaap.bcapi.client;
-
-/**
- * Holds the status code and body that result from accessing an HTTP URL.
- */
-public class HttpStatusAndResponse<ResponseType> {
-
-	private int statusCode;
-	private ResponseType response;
-
-	public HttpStatusAndResponse(int status, ResponseType resp) {
-		this.statusCode = status;
-		this.response = resp;
-	}
-
-	public int getStatusCode() {
-		return statusCode;
-	}
-
-	public void setStatusCode(final int code) {
-		this.statusCode = code;
-	}
-
-	public ResponseType getResponse() {
-		return response;
-	}
-
-	public void setResponse(ResponseType response) {
-		this.response = response;
-	}
-
-	/**
-	 * Convenience method to avoid testing for null and calling .toString()
-	 * 
-	 * @return String version of the response object; null if the object is
-	 *         null.
-	 */
-	public String getResponseString() {
-		return response == null ? null : response.toString();
-	}
-
-	@Override
-	public String toString() {
-		return "HttpStatusAndResponse[" + Integer.toString(statusCode) + ";"
-				+ (response == null ? "" : response.toString()) + "]";
-	}
-}
diff --git a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/IRestClientConstants.java b/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/IRestClientConstants.java
deleted file mode 100644
index 10b8189..0000000
--- a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/IRestClientConstants.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller REST Client
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * 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.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaap.bcapi.client;
-
-public interface IRestClientConstants {
-
-	/**
-	 * Default configuration file to be found on classpath
-	 */
-	public static final String PROPERTY_FILE_NAME = "bc-rest-client.properties";
-
-	/** Base URL of the Bus Controller REST service API; e.g., 
-	 * 
-	 */
-	public static final String DMAAP_BUS_CONTROLLER_REST_URL = "dmaap_bus_controller_rest_url";
-
-	
-}
diff --git a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/SimpleRestClientBase.java b/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/SimpleRestClientBase.java
deleted file mode 100644
index 1e5b064..0000000
--- a/dcae_dmaapbc_client/src/main/java/org/openecomp/dcae/dmaap/bcapi/client/SimpleRestClientBase.java
+++ /dev/null
@@ -1,273 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller REST Client
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * 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.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaap.bcapi.client;
-
-import java.io.IOException;
-import java.net.URI;
-
-import org.apache.http.Consts;
-import org.apache.http.HttpEntity;
-import org.apache.http.HttpHost;
-import org.apache.http.auth.AuthScope;
-import org.apache.http.auth.UsernamePasswordCredentials;
-import org.apache.http.client.AuthCache;
-import org.apache.http.client.ClientProtocolException;
-import org.apache.http.client.CredentialsProvider;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.config.RequestConfig.Builder;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpDelete;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.client.methods.HttpPut;
-import org.apache.http.client.methods.HttpRequestBase;
-import org.apache.http.client.protocol.HttpClientContext;
-import org.apache.http.client.utils.URIBuilder;
-import org.apache.http.entity.ContentType;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.auth.BasicScheme;
-import org.apache.http.impl.client.BasicAuthCache;
-import org.apache.http.impl.client.BasicCredentialsProvider;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.util.EntityUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Provides a basic client to access a REST endpoint, optionally using HTTP
- * basic authentication.
- * 
- * Caveat: If HTTPS access is used and the server uses a self-signed
- * certificate, the local trust store must be extended appropriately. The client
- * throws exceptions if the JVM cannot validate the server certificate.
- */
-public class SimpleRestClientBase {
-
-	private static Logger logger = LoggerFactory.getLogger(SimpleRestClientBase.class);
-
-	/**
-	 * Credentials for HTTP basic authentication (optional).
-	 */
-	private final String username;
-	private final String password;
-
-	/**
-	 * Timeouts (optional)
-	 */
-	private Integer connectTimeoutMs = null;
-    private Integer connectionRequestTimeoutMs = null;
-    private Integer socketTimeoutMs = null;
-    
-    /**
-	 * Constructs a client that does not use any authentication and uses Apache HTTPD client default values for timeouts.
-	 */
-	public SimpleRestClientBase() {
-		this(null, null, null, null, null);
-	}
-
-	/**
-	 * Convenience constructor to build a client that uses the specified username and password for
-	 * basic HTTP authentication on all requests.  In other words, this client
-	 * pre-emptively sends the "Basic" header instead of first trying the
-	 * request without, failing, negotiating, then sending with credentials.
-	 * 
-	 * @param username User name for basic HTTP authentication.
-	 * @param password Password for basic HTTP authentication.
-	 */
-	public SimpleRestClientBase(final String username, final String password) {
-		this(username, password, null, null, null);
-	}
-	
-	/**
-	 * Convenience constructor to build a client that uses the specified timeouts 
-	 * on all requests.
-	 *
-	 * @param connectTimeoutMs
-	 * Connection timeout, in milliseconds
-	 * @param connectionRequestTimeoutMs
-	 * Connection request timeout, in milliseconds
-	 * @param socketTimeoutMs
-	 * Socket timeout, in milliseconds
-	 */
-	public SimpleRestClientBase(final Integer connectTimeoutMs, final Integer connectionRequestTimeoutMs, final Integer socketTimeoutMs) {	
-		this(null, null, connectTimeoutMs, connectionRequestTimeoutMs, socketTimeoutMs);
-	}
-
-	/**
-	 * Constructs a client with the specified credentials and timeout values.
-	 * @param username User name for basic HTTP authentication;  ignored if null
-	 * @param password Password for basic HTTP authentication;  ignored if null
-	 * @param connectTimeoutMs ignored if null
-	 * @param connectionRequestTimeoutMs ignored if null
-	 * @param socketTimeoutMs ignored if null
-	 */
-	public SimpleRestClientBase(final String username, final String password, final Integer connectTimeoutMs, final Integer connectionRequestTimeoutMs, final Integer socketTimeoutMs) {
-		this.username = username;
-		this.password = password;
-		this.connectTimeoutMs = null;
-    	this.connectionRequestTimeoutMs = null;
-    	this.socketTimeoutMs = null;
-	}
-
-
-	/**
-	 * Constructs and sends a GET request for the URI.
-	 * 
-	 * @param uri
-	 *            REST endpoint
-	 * @return Result of the get
-	 * @throws Exception
-	 */
-	public HttpStatusAndResponse<String> getRestContent(final URI uri) throws Exception {
-		HttpGet httpGet = new HttpGet(uri);
-		return doRestRequest(httpGet);
-	}
-
-	/**
-	 * Constructs and sends a POST request using the specified body.
-	 * 
-	 * @param uri
-	 *            REST endpoint
-	 * @param json
-	 *            Content to post
-	 * @return Result of the post; null if an error happens
-	 * @throws Exception
-	 */
-	public HttpStatusAndResponse<String> postRestContent(final URI uri, final String json) throws Exception {
-		HttpPost httpPost = new HttpPost(uri);
-		StringEntity postEntity = new StringEntity(json, ContentType.create("application/json", Consts.UTF_8));
-		httpPost.setEntity(postEntity);
-		return doRestRequest(httpPost);
-	}
-
-	/**
-	 * Constructs and sends a PUT request using the specified body.
-	 * 
-	 * @param uri
-	 *            REST endpoint
-	 * @param json
-	 *            Content to put
-	 * @return Result of the put; null if an error happens
-	 * @throws Exception
-	 */
-	public HttpStatusAndResponse<String> putRestContent(final URI uri, final String json) throws Exception {
-		HttpPut httpPut = new HttpPut(uri);
-		StringEntity postEntity = new StringEntity(json, ContentType.create("application/json", Consts.UTF_8));
-		httpPut.setEntity(postEntity);
-		return doRestRequest(httpPut);
-	}
-
-	/**
-	 * Constructs and sends a DELETE request for the URI.
-	 * 
-	 * @param uri
-	 *            REST endpoint
-	 * @return Result of the get
-	 * @throws Exception
-	 */
-	public HttpStatusAndResponse<String> deleteRestContent(final URI uri) throws Exception {
-		HttpDelete httpDel = new HttpDelete(uri);
-		return doRestRequest(httpDel);
-	}
-
-	/**
-	 * Executes the specified request and gathers the response.
-	 * 
-	 * @param request
-	 *            HttpGet, HttpPost, etc.
-	 * @return Status code and response body
-	 * @throws ClientProtocolException
-	 * @throws IOException
-	 */
-	private HttpStatusAndResponse<String> doRestRequest(final HttpRequestBase request)
-			throws ClientProtocolException, IOException {
-
-		// Set up authentication if needed
-		final HttpClientContext context = HttpClientContext.create();
-		if (this.username != null || this.password != null) {
-			UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(this.username, this.password);
-			CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
-			credentialsProvider.setCredentials(AuthScope.ANY, credentials);
-			context.setCredentialsProvider(credentialsProvider);
-			
-			HttpHost host = new HttpHost(request.getURI().getHost(), request.getURI().getPort(), request.getURI().getScheme());			
-			AuthCache authCache = new BasicAuthCache();
-			authCache.put(host, new BasicScheme());
-			context.setAuthCache(authCache);
-		}
-		final Builder requestConfigBuilder = RequestConfig.custom();
-		if (connectionRequestTimeoutMs != null)
-			requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeoutMs);
-		if (connectTimeoutMs != null)
-			requestConfigBuilder.setConnectTimeout(connectTimeoutMs);
-		if (socketTimeoutMs != null)
-			requestConfigBuilder.setSocketTimeout(socketTimeoutMs);
-		RequestConfig requestConfig = requestConfigBuilder.build();
-		final CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(requestConfig).build();
-		CloseableHttpResponse response = null;
-		String responseJson = null;
-		try {
-			response = httpClient.execute(request, context);
-			// Some methods return non-200 on success
-			logger.debug("doRestRequest: status is {}", response.getStatusLine());
-			HttpEntity entity = response.getEntity();
-			// This is common; don't warn
-			if (entity == null) {
-				logger.debug("doRestRequest: Entity is null");
-			} else {
-				// entity content length is never set;
-				// this naively tries to read everything.
-				responseJson = EntityUtils.toString(entity);
-				EntityUtils.consume(entity);
-				// Don't give back empty string;
-				// it has no more meaning than null.
-				if (responseJson.length() == 0)
-					responseJson = null;
-			}
-		} finally {
-			if (response != null)
-				response.close();
-		}
-		if (response == null)
-			return null;
-		return new HttpStatusAndResponse<String>(response.getStatusLine().getStatusCode(), responseJson);
-	}
-
-	/**
-	 * Basic test invocation.
-	 * 
-	 * @param args
-	 *            Expect 1 argument, the URL of a REST endpoint.
-	 * @throws Exception
-	 *             if anything goes wrong
-	 */
-	public static void main(String[] args) throws Exception {
-		if (args.length != 1)
-			throw new IllegalArgumentException("Expect 1 argument: REST URL for GET");
-		SimpleRestClientBase client = new SimpleRestClientBase();
-		URIBuilder uriBuilder = new URIBuilder(args[0]);
-		URI uri = uriBuilder.build();
-		HttpStatusAndResponse<String> hsr = client.getRestContent(uri);
-		System.out.println("Response code is " + hsr.getStatusCode());
-		System.out.println(hsr.getResponseString());
-		System.out.println("main ends.");
-	}
-}
diff --git a/dcae_dmaapbc_client/src/main/resources/logback.xml b/dcae_dmaapbc_client/src/main/resources/logback.xml
deleted file mode 100644
index 39d3b0f..0000000
--- a/dcae_dmaapbc_client/src/main/resources/logback.xml
+++ /dev/null
@@ -1,24 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE xml>
-<configuration>
-
-	<!-- Configuration of logback library for rest client, reused from http://logback.qos.ch/manual/configuration.html -->
-
-	<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
-		<encoder>
-			<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n
-			</pattern>
-		</encoder>
-	</appender>
-
-	<root level="debug">
-		<appender-ref ref="STDOUT" />
-	</root>
-
-	<!-- allow our classes to be chatty -->
-	<logger name="org.openecomp.ecomp.dcae.dmaap.bcapi.client" level="debug" />
-
-	<!-- http client is chatty at level debug -->
-	<logger name="org.apache.http" level="info" />
-
-</configuration>
diff --git a/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java b/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java
deleted file mode 100644
index e90c7b8..0000000
--- a/dcae_dmaapbc_client/src/test/java/org/openecomp/dcae/dmaapbc/TestDmaapBcRestClient.java
+++ /dev/null
@@ -1,159 +0,0 @@
-package org.openecomp.dcae.dmaapbc;
-
-import java.util.List;
-
-import org.junit.Test;
-import org.openecomp.dcae.dmaap.bcapi.client.DmaapBcRestClient;
-import org.openecomp.dcae.dmaap.bcapi.client.HttpStatusAndResponse;
-import org.openecomp.dcae.dmaapbc.model.DmaapObject;
-import org.openecomp.dcae.dmaapbc.model.Feed;
-import org.openecomp.dcae.dmaapbc.model.Topic;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class TestDmaapBcRestClient {
-
-	private static Logger logger = LoggerFactory.getLogger(TestDmaapBcRestClient.class);
-
-	/**
-	 * Exercises some of the DMaaP Bus Controller client's functionality.
-	 */
-	@Test
-	public void test() throws Exception {
-		DmaapBcRestClient client = new DmaapBcRestClient("https://host:8443/webapi/",
-				"host", "MechIdPassword");
-
-		// This may help when in a hurry, but it's dangerous.
-		// client.setFailOnUnknownProperties(false);
-
-		DmaapObject dmaap = client.getDmaap();
-		if (dmaap == null)
-			logger.warn("Failed to get DMAAP");
-		else
-			logger.info("DMAAP is " + dmaap.toString());
-
-		List<DmaapObject> locs = client.getDcaeLocations();
-		if (locs == null) {
-			logger.warn("Failed to get DCAE locations");
-		} else {
-			logger.info("Loc count is " + locs.size());
-			for (DmaapObject loc : locs)
-				logger.info("Location is: " + loc.toString());
-		}
-
-		List<DmaapObject> nodes = client.getDRNodes();
-		if (nodes == null) {
-			logger.warn("Failed to get nodes");
-		} else {
-			logger.info("node count is " + nodes.size());
-			for (DmaapObject node : nodes)
-				logger.info("Nodeis: " + node.toString());
-		}
-
-		List<DmaapObject> drPubs = client.getDRPubs();
-		if (drPubs == null) {
-			logger.warn("Failed to get DR pubs");
-		} else {
-			logger.info("DR_Pub count is " + drPubs.size());
-			for (DmaapObject pub : drPubs)
-				logger.info("DR_Pub is: " + pub.toString());
-		}
-		List<DmaapObject> drSubs = client.getDRSubs();
-		if (drSubs == null) {
-			logger.warn("Failed to get DR subs");
-		} else {
-			logger.info("DR_Sub count is " + drSubs.size());
-			for (DmaapObject sub : drSubs)
-				logger.info("DR_Sub is: " + sub.toString());
-		}
-
-		List<DmaapObject> feeds = client.getFeeds();
-		if (feeds == null) {
-			logger.warn("Failed to get feeds");
-		} else {
-			logger.info("Feed count is " + feeds.size());
-			for (DmaapObject feed : feeds)
-				logger.info("Feed is: " + feed.toString());
-		}
-		List<DmaapObject> topics = client.getTopics();
-		if (topics == null) {
-			logger.warn("Failed to get topics");
-		} else {
-			logger.info("Topic count is " + topics.size());
-			for (DmaapObject topic : topics)
-				logger.info("Topic is: " + topic.toString());
-		}
-		List<DmaapObject> clients = client.getMRClients();
-		if (clients == null) {
-			logger.warn("Failed to get MR clients");
-		} else {
-			logger.info("MR client count is " + clients.size());
-			for (DmaapObject mrc : clients)
-				logger.info("MR client is: " + mrc.toString());
-		}
-		List<DmaapObject> clusters = client.getMRClusters();
-		if (clusters == null) {
-			logger.warn("Failed to get MR clusters");
-		} else {
-			logger.info("MR cluster count is " + clusters.size());
-			for (DmaapObject mrc : clusters)
-				logger.info("MR cluster is: " + mrc.toString());
-		}
-
-		// Create and delete feed
-
-		Feed feed = (Feed) feeds.get(0);
-		final String feedId = "987654321";
-		final String feedName = "TestFeed1234567890";
-		final String feedUrl = "http://host.com/foo/bar";
-		feed.setFeedId(feedId);
-		feed.setFeedName(feedName);
-		feed.setPublishURL(feedUrl);
-		HttpStatusAndResponse<Object> addFeedResp = client.postFeed(feed);
-		if (addFeedResp.getStatusCode() == 200)
-			logger.info("add feed succeeded, response is " + addFeedResp);
-		else
-			logger.error("add feed failed, response is " + addFeedResp);
-
-		DmaapObject getFeedResp = client.getFeed(feedId);
-		logger.info("get feed response is " + getFeedResp);
-		HttpStatusAndResponse<Object> delFeedResp = client.deleteFeed(feedId);
-		if (delFeedResp.getStatusCode() == 200)
-			logger.info("delete feed succeeded, response is " + delFeedResp);
-		else
-			logger.error("delete feed failed, response is " + delFeedResp);
-
-		// Attempt to create empty feed should fail -- but does not
-		// Feed emptyFeed = new Feed();
-		// HttpStatusAndResponse<Object> addEmptyFeedResp =
-		// client.postFeed(emptyFeed);
-		// if (addEmptyFeedResp.getStatusCode() == 200)
-		// logger.info("add feed succeeded, response is " + addFeedResp);
-		// else
-		// logger.error("add feed failed, response is " + addFeedResp);
-
-		// Create and delete topic
-
-		Topic topic = new Topic();
-		final String fqtn = "host";
-		topic.setFqtn(fqtn);
-		HttpStatusAndResponse<Object> createTopicResp = client.postTopic(topic);
-		logger.info("create topic response is " + createTopicResp);
-		DmaapObject getTopicResp = client.getTopic(fqtn);
-		logger.info("get topic response is " + getTopicResp);
-		HttpStatusAndResponse<Object> delTopic = client.deleteTopic(fqtn);
-		if (delTopic.getStatusCode() == 200)
-			logger.info("del topic succeeded, response is " + delTopic);
-		else
-			logger.error("del topic failed, response is " + delTopic);
-		HttpStatusAndResponse<Object> delTopicMissing = client.deleteTopic(fqtn);
-		if (delTopicMissing.getStatusCode() == 204)
-			logger.info("del of missing topic succeeded, response is " + delTopicMissing);
-		else
-			logger.error("del of missing topic failed, response is " + delTopic);
-
-		logger.info("ends");
-
-	}
-
-}