1 files changed, 7 insertions, 40 deletions
diff --git a/src/main/java/org/onap/aai/datarouter/query/QueryRouter.java b/src/main/java/org/onap/aai/datarouter/query/QueryRouter.java
index aabeac2..07b4e79 100644
--- a/src/main/java/org/onap/aai/datarouter/query/QueryRouter.java
+++ b/src/main/java/org/onap/aai/datarouter/query/QueryRouter.java
@@ -20,55 +20,22 @@
  */
 package org.onap.aai.datarouter.query;
 
+import java.util.List;
 import java.util.Map;
-import java.util.UUID;
 
-import org.apache.camel.Exchange;
 import org.onap.aai.cl.api.Logger;
 import org.onap.aai.cl.eelf.LoggerFactory;
-import org.onap.aai.cl.mdc.MdcContext;
+import org.onap.aai.datarouter.exception.DataRouterException;
 
-
-public abstract class QueryRouter {
+public interface QueryRouter {
   Logger logger = LoggerFactory.getInstance().getLogger(QueryRouter.class.getName());
 
 
-  protected static final String SERVICE_NAME = "DATA-ROUTER";
-  /** HTTP header containing the ECOMP Request Id */
-  protected static final String HEADER_TRANS_ID = "X-TransactionId";
-  
-  /** HTTP header containing the calling application Id */
-  protected static final String HEADER_FROM_APP_ID = "X-FromAppId";
-  
-  /** HTTP header containing the calling host details */
-  protected static final String HEADER_FROM_HOST = "Host";
-  
-  /** HTTP header containing the calling host details */
-  protected static final String DATA_ROUTER_PORT = "9502";
-  
 
-  public abstract void setQueryRequest(Exchange exchange) ;
-  
-  public abstract void setQueryResponse(Exchange exchange);
-  
-  protected String getTxId(final Exchange exchange){
-    String txId = exchange.getIn().getHeader("X-TransactionId",String.class);    
-    return ((txId==null||txId.isEmpty())?UUID.randomUUID().toString():txId);
-  }
-  
-  protected boolean checkRecursion(String url){
-   return url.contains(DATA_ROUTER_PORT);
-  }
-  
-  protected void setMDC(final Exchange exchange) {
-    String transId = exchange.getIn().getHeader(HEADER_TRANS_ID, String.class);
-    String appId = exchange.getIn().getHeader(HEADER_FROM_APP_ID, String.class);
-    String hostId = exchange.getIn().getHeader(HEADER_FROM_HOST, String.class);
+  /** HTTP header containing the calling host details */
+  static final String DATA_ROUTER_PORT = "9502";
 
-    // Set MDC transaction id, calling service name, calling service id,
-    // partner name, client address
-    MdcContext.initialize(transId, "DataRouter", "", appId, hostId);
-  }
- 
+  public String process(String urlContext, String queryParams, Map<String, List<String>> headers)
+      throws DataRouterException;
 
 }