update the package name

Issue-ID: DMAAP-858
Change-Id: Ia69621ea6ad2ec2ec525800af2a7d3f73aef82ed
Signed-off-by: sunil unnava <sunil.unnava@att.com>

1 files changed, 0 insertions, 179 deletions

diff --git a/src/main/java/com/att/nsa/mr/client/impl/MRConstants.java b/src/main/java/com/att/nsa/mr/client/impl/MRConstants.java
deleted file mode 100644
index cb0fc31..0000000
--- a/src/main/java/com/att/nsa/mr/client/impl/MRConstants.java
+++ /dev/null
@@ -1,179 +0,0 @@
-/*******************************************************************************
- *  ============LICENSE_START=======================================================
- *  org.onap.dmaap
- *  ================================================================================
- *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
- *  ================================================================================
- *  Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with the License.
- *  You may obtain a copy of the License at
- *        http://www.apache.org/licenses/LICENSE-2.0
- *  
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
- *  ============LICENSE_END=========================================================
- *
- *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
- *  
- *******************************************************************************/
-package com.att.nsa.mr.client.impl;
-
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-import org.apache.http.HttpHost;
-
-class MRConstants
-{
-	private static final String PROTOCOL = "http";
-	public static final String context = "/";
-	public static final String kBasePath = "events/";
-	public static final int kStdMRServicePort = 8080;
-
-	public static String escape ( String s )
-	{
-		try
-		{
-			return URLEncoder.encode ( s, "UTF-8");
-		}
-		catch ( UnsupportedEncodingException e )
-		{
-			throw new IllegalArgumentException(e);
-		}
-	}
-
-	public static String makeUrl ( String rawTopic )
-	{
-		final String cleanTopic = escape ( rawTopic );
-		
-		final StringBuffer url = new StringBuffer().
-			append ( MRConstants.context ).
-			append ( MRConstants.kBasePath ).
-			append ( cleanTopic );
-		return url.toString ();
-	}
-	
-	public static String makeUrl ( final String host, final String rawTopic )
-	{
-		final String cleanTopic = escape ( rawTopic );
-
-		final StringBuffer url = new StringBuffer();
-		
-		if (!host.startsWith("http") || !host.startsWith("https") ) {
-			url.append( PROTOCOL + "://" );
-		}
-		url.append(host);
-		url.append ( MRConstants.context );
-		url.append ( MRConstants.kBasePath );
-		url.append ( cleanTopic );
-		return url.toString ();
-	}
-
-	public static String makeUrl ( final String host, final String rawTopic, final String transferprotocol,final String parttion )
-	{
-		final String cleanTopic = escape ( rawTopic );
-
-		final StringBuffer url = new StringBuffer();
-		
-		if (transferprotocol !=null && !transferprotocol.equals("")) {
-			url.append( transferprotocol + "://" );
-		}else{
-			url.append( PROTOCOL + "://" );
-		}
-		url.append(host);
-		url.append ( MRConstants.context );
-		url.append ( MRConstants.kBasePath );
-		url.append ( cleanTopic );
-		if(parttion!=null && !parttion.equalsIgnoreCase(""))
-			url.append("?partitionKey=").append(parttion);
-		return url.toString ();
-	}
-	public static String makeConsumerUrl ( String topic, String rawConsumerGroup, String rawConsumerId )
-	{
-		final String cleanConsumerGroup = escape ( rawConsumerGroup );
-		final String cleanConsumerId = escape ( rawConsumerId );
-		return MRConstants.context + MRConstants.kBasePath + topic + "/" + cleanConsumerGroup + "/" + cleanConsumerId;
-	}
-
-	/**
-	 * Create a list of HttpHosts from an input list of strings. Input strings have
-	 * host[:port] as format. If the port section is not provided, the default port is used.
-	 * 
-	 * @param hosts
-	 * @return a list of hosts
-	 */
-	public static List<HttpHost> createHostsList(Collection<String> hosts)
-	{
-		final ArrayList<HttpHost> convertedHosts = new ArrayList<HttpHost> ();
-		for ( String host : hosts )
-		{
-			if ( host.length () == 0 ) continue;
-			convertedHosts.add ( hostForString ( host ) );
-		}
-		return convertedHosts;
-	}
-
-	/**
-	 * Return an HttpHost from an input string. Input string has
-	 * host[:port] as format. If the port section is not provided, the default port is used.
-	 * 
-	 * @param hosts
-	 * @return a list of hosts
-	 */
-	public static HttpHost hostForString ( String host )
-	{
-		if ( host.length() < 1 ) throw new IllegalArgumentException ( "An empty host entry is invalid." );
-		
-		String hostPart = host;
-		int port = kStdMRServicePort;
-
-		final int colon = host.indexOf ( ':' );
-		if ( colon == 0 ) throw new IllegalArgumentException ( "Host entry '" + host + "' is invalid." );
-		if ( colon > 0 )
-		{
-			hostPart = host.substring ( 0, colon ).trim();
-
-			final String portPart = host.substring ( colon + 1 ).trim();
-			if ( portPart.length () > 0 )
-			{
-				try
-				{
-					port = Integer.parseInt ( portPart );
-				}
-				catch ( NumberFormatException x )
-				{
-					throw new IllegalArgumentException ( "Host entry '" + host + "' is invalid.", x );
-				}
-			}
-			// else: use default port on "foo:"
-		}
-
-		return new HttpHost ( hostPart, port );
-	}
-
-	public static String makeConsumerUrl(String host, String fTopic, String fGroup, String fId,final String transferprotocol) {
-		final String cleanConsumerGroup = escape ( fGroup );
-		final String cleanConsumerId = escape ( fId );
-		
-		StringBuffer url = new StringBuffer();
-		
-		if (transferprotocol !=null && !transferprotocol.equals("")) {
-			url.append( transferprotocol + "://" );
-		}else{
-			url.append( PROTOCOL + "://" );
-		}
-		
-		url.append(host);
-		url.append(context);
-		url.append(kBasePath);
-		url.append(fTopic + "/" + cleanConsumerGroup + "/" + cleanConsumerId);
-		
-		return url.toString();
-	}
-}