Refactor to use org.onap local packages

This is stage 1 of refactoring to use org.onap instead of org.openecomp
in java packages and class names.
Leaving the update from openecomp portalsdk to onap epsdk for a future
exercise since I'm trying to get a standalone GUI working (i.e. non-portal).

Issue-ID: DMAAP-159

Change-Id: I6a9368c66fa3603b1d9984f600802326ff2f0592
Signed-off-by: Dominic Lunanuova <dgl@research.att.com>

1 files changed, 0 insertions, 1495 deletions

diff --git a/dcae_dmaapbc_webapp/dbca-common/src/main/java/org/openecomp/dcae/dmaapbc/client/DmaapBcRestClient.java b/dcae_dmaapbc_webapp/dbca-common/src/main/java/org/openecomp/dcae/dmaapbc/client/DmaapBcRestClient.java
deleted file mode 100644
index 39d28dd..0000000
--- a/dcae_dmaapbc_webapp/dbca-common/src/main/java/org/openecomp/dcae/dmaapbc/client/DmaapBcRestClient.java
+++ /dev/null
@@ -1,1495 +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.dmaapbc.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
-	 *            URL of the endpoint
-	 */
-	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
-	 *            URL of the endpoint
-	 * @param username
-	 *            User name
-	 * @param password
-	 *            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
-	 *            Dmaap properties
-	 * @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
-	 *            Dmaap properties
-	 * @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
-	 *            Data router publisher properties
-	 * @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
-	 *            Data router subscriber properties
-	 * @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
-	 *            Data router feed properties
-	 * @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
-	 *            Message router topic properties
-	 * @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
-	 *            Message router client properties
-	 * @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
-	 *            Message router cluster properties
-	 * @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;
-	}
-
-}