Revert package name changes

Reverted package name changes to avoid any potential issues. Renamed maven
    group id only.

Issue-id: DMAAP-74
Change-Id: I4ca4537d48e5723b2939148e5bd83645ee20dd30
Signed-off-by: Varun Gudisena <vg411h@att.com>

21 files changed, 400 insertions, 0 deletions

diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/conf/FileMonitorBeans.xml b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/FileMonitorBeans.xml
new file mode 100644
index 0000000..22ae528
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/FileMonitorBeans.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+     ============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.
+     
+ -->
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
+
+	<bean
+		class="org.springframework.context.annotation.CommonAnnotationBeanPostProcessor" />
+		
+	<bean id="ServicePropertiesListener" class="com.att.nsa.dmaap.filemonitor.ServicePropertiesListener" />
+	
+	<bean id="ServicePropertiesMap" class="com.att.nsa.dmaap.filemonitor.ServicePropertiesMap" />
+
+	<bean id="ServicePropertyService" class="com.att.nsa.dmaap.filemonitor.ServicePropertyService">
+		<property name="loadOnStartup" value="false" />
+		<property name="fileChangedListener" ref="ServicePropertiesListener" />
+		<property name="filePropertiesMap" ref="ServicePropertiesMap" />
+		<property name="ssfFileMonitorPollingInterval" value="15" />
+		<property name="ssfFileMonitorThreadpoolSize" value="10" />
+	</bean>
+</beans>
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/conf/HelloWorldBeans.xml b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/HelloWorldBeans.xml
new file mode 100644
index 0000000..c27414f
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/HelloWorldBeans.xml
@@ -0,0 +1,29 @@
+<!--
+     ============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.
+     
+ -->
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="
+	       http://www.springframework.org/schema/beans
+	       http://www.springframework.org/schema/beans/spring-beans.xsd">
+	<bean id="helloWorld" name="helloWorld"
+		class="com.att.nsa.dmaap.HelloWorld" />
+</beans>		
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/conf/jaxrsBeans.groovy b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/jaxrsBeans.groovy
new file mode 100644
index 0000000..430e723
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/jaxrsBeans.groovy
@@ -0,0 +1,22 @@
+	beans{
+	xmlns cxf: "http://camel.apache.org/schema/cxf"
+	xmlns jaxrs: "http://cxf.apache.org/jaxrs"
+	xmlns util: "http://www.springframework.org/schema/util"
+	
+	echoService(com.att.nsa.dmaap.JaxrsEchoService)
+	userService(com.att.nsa.dmaap.JaxrsUserService)
+	topicService(com.att.nsa.dmaap.service.TopicRestService)
+	eventService(com.att.nsa.dmaap.service.EventsRestService)
+	adminService(com.att.nsa.dmaap.service.AdminRestService)
+	apiKeyService(com.att.nsa.dmaap.service.ApiKeysRestService)
+	metricsService(com.att.nsa.dmaap.service.MetricsRestService)
+	transactionService(com.att.nsa.dmaap.service.TransactionRestService)
+	UIService(com.att.nsa.dmaap.service.UIRestServices)
+	mirrorService(com.att.nsa.dmaap.service.MMRestService)
+	
+	util.list(id: 'jaxrsServices') {
+		ref(bean:'echoService')
+		ref(bean:'userService')
+		
+	}
+}
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/conf/serviceBeans.xml b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/serviceBeans.xml
new file mode 100644
index 0000000..1a499f2
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/conf/serviceBeans.xml
@@ -0,0 +1,134 @@
+<!--
+     ============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.
+     
+ -->
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:context="http://www.springframework.org/schema/context"
+	xsi:schemaLocation="
+	       http://www.springframework.org/schema/beans
+	       http://www.springframework.org/schema/beans/spring-beans.xsd
+	       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+	
+	<!-- Dependency Injection with annotations -->
+	<context:component-scan
+		base-package="com.att.nsa.cambria.utils, com.att.nsa.cambria, com.att.nsa.cambria.rest,
+	com.att.nsa.cambria.service.impl,com.att.nsa.cambria.beans,com.att.nsa.cambria.security,
+	com.att.nsa.cambria.transaction,com.att.nsa.cambria.exception,com.att.nsa.dmaap,com.att.nsa.dmaap.service,com.att.nsa.dmaap.util" />
+	
+	<context:property-placeholder
+		location="file:${AJSC_HOME}/bundleconfig/etc/appprops/MsgRtrApi.properties,file:${AJSC_HOME}/etc/DMaaPErrorMesaages.properties"/>
+		
+		<bean id="jsonProvider" class="org.apache.cxf.jaxrs.provider.json.JSONProvider">
+			 <property name="dropRootElement" value="true" />
+        	<property name="supportUnwrapped" value="true" />
+        </bean>
+		
+		<bean id="jacksonProvider" class="org.codehaus.jackson.jaxrs.JacksonJsonProvider" />
+		
+		<bean id="cambriaExMapper" class="com.att.nsa.dmaap.DMaaPCambriaExceptionMapper" />
+    
+    	<bean id="webExMapper" class="com.att.nsa.dmaap.DMaaPWebExceptionMapper" />
+    
+		
+	<!-- Your bean definitions goes here -->
+<!-- 	<bean id="performanceLog" name="performanceLog" class="com.att.ajsc.csi.logging.PerformanceTracking" /> -->
+<!-- 	<bean id="processRestletHeaders" name="processRestletHeaders" class="ajsc.restlet.ProcessRestletHeaders" /> -->
+		<bean id="servicePropsBean" name="servicePropsBean" 
+		class="com.att.nsa.dmaap.util.ServicePropertiesMapBean" />
+		
+		<!-- Msgrtr beans -->
+		<bean id="propertyReader" class="com.att.nsa.cambria.utils.PropertyReader" />
+		<bean
+		class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
+		<!-- Next value is the full qualified name of the static setter including 
+			method name -->
+		<property name="staticMethod"
+			value="com.att.nsa.cambria.beans.DMaaPKafkaConsumerFactory.populateKafkaInternalDefaultsMap" />
+		<!--  <property name="arguments">
+			<list>
+				<ref bean="propertyReader" />
+			</list>
+		</property>-->
+	</bean>
+
+	<bean id="drumlinRequestRouter"
+		class="com.att.nsa.drumlin.service.framework.routing.DrumlinRequestRouter" />
+
+	<bean id="dMaaPMetricsSet" class="com.att.nsa.cambria.beans.DMaaPMetricsSet">
+		 <constructor-arg ref="propertyReader" /> 
+	</bean>
+
+	<bean id="dMaaPZkClient" class=" com.att.nsa.cambria.beans.DMaaPZkClient">
+		<constructor-arg ref="propertyReader" />
+	</bean>
+
+	<bean id="dMaaPZkConfigDb" class="com.att.nsa.cambria.beans.DMaaPZkConfigDb">
+		<constructor-arg ref="dMaaPZkClient" />
+		<constructor-arg ref="propertyReader" />
+	</bean>
+	
+
+	<bean id="kafkaPublisher" class=" com.att.nsa.cambria.backends.kafka.KafkaPublisher">
+		<constructor-arg ref="propertyReader" />
+	</bean>
+
+	<bean id="dMaaPKafkaConsumerFactory" class=" com.att.nsa.cambria.beans.DMaaPKafkaConsumerFactory">
+		<constructor-arg ref="propertyReader" /> 
+		<constructor-arg ref="dMaaPMetricsSet" />
+		<constructor-arg ref="curator" />
+	</bean>
+
+	<bean id="curator" class="com.att.nsa.cambria.utils.DMaaPCuratorFactory"
+		factory-method="getCurator">
+		<constructor-arg ref="propertyReader" />
+	</bean>
+
+	<bean id="dMaaPKafkaMetaBroker" class=" com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker">
+		<constructor-arg ref="propertyReader" />
+		<constructor-arg ref="dMaaPZkClient" />
+		<constructor-arg ref="dMaaPZkConfigDb" />
+	</bean>
+
+	<bean id="q" class=" com.att.nsa.cambria.backends.memory.MemoryQueue" />
+
+	<bean id="mmb" class=" com.att.nsa.cambria.backends.memory.MemoryMetaBroker">
+		<constructor-arg ref="q" />
+		<constructor-arg ref="dMaaPZkConfigDb" />
+		<!-- <constructor-arg ref="propertyReader" />-->
+	</bean>
+
+	<bean id="dMaaPNsaApiDb" class="com.att.nsa.cambria.beans.DMaaPNsaApiDb"
+		factory-method="buildApiKeyDb">
+		<constructor-arg ref="propertyReader" />
+		<constructor-arg ref="dMaaPZkConfigDb" />
+	</bean>
+
+	<!-- <bean id="dMaaPTranDb" class="com.att.nsa.cambria.transaction.DMaaPTransactionDB" 
+		factory-method="buildTransactionDb"> <constructor-arg ref="propertyReader" 
+		/> <constructor-arg ref="dMaaPZkConfigDb" /> </bean> -->
+
+	<bean id="dMaaPAuthenticatorImpl" class="com.att.nsa.cambria.security.DMaaPAuthenticatorImpl">
+		<constructor-arg ref="dMaaPNsaApiDb" />
+	</bean>
+	<bean id="defLength" class="com.att.nsa.filter.DefaultLength">
+		<property name="defaultLength" value="${maxcontentlength}"></property>
+	</bean>
+</beans>		
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/docs/README.txt b/src/main/ajsc/dmaap_v1/dmaap/v1/docs/README.txt
new file mode 100644
index 0000000..3707179
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/docs/README.txt
@@ -0,0 +1 @@
+Place any docs here that you want to access within the ajsc upon deployment of your service.
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/lib/README.txt b/src/main/ajsc/dmaap_v1/dmaap/v1/lib/README.txt
new file mode 100644
index 0000000..639e21b
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/lib/README.txt
@@ -0,0 +1 @@
+3rd party JAR's needed by your jars (if any) for a ajsc deployment package go here...
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/props/module.props b/src/main/ajsc/dmaap_v1/dmaap/v1/props/module.props
new file mode 100644
index 0000000..17ebc08
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/props/module.props
@@ -0,0 +1 @@
+EXAMPLE.PROPERTY=EXAMLE_VALUE
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/UIService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/UIService.route
new file mode 100644
index 0000000..d9a0fa9
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/UIService.route
@@ -0,0 +1,9 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///UI?matchOnUriPrefix=true" />
+  <to uri="cxfbean:UIService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+    <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService.route
new file mode 100644
index 0000000..fc0ab5c
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService.route
@@ -0,0 +1,10 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///admin?matchOnUriPrefix=true" />
+  <to uri="cxfbean:adminService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+   <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService2.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService2.route
new file mode 100644
index 0000000..8eb75f0
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/adminService2.route
@@ -0,0 +1,10 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///__module_ajsc_namespace_version__/admin?matchOnUriPrefix=true" />
+    <to uri="cxfbean:adminService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+   <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService.route
new file mode 100644
index 0000000..4d2f3b6
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService.route
@@ -0,0 +1,10 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///__module_ajsc_namespace_version__/apiKeys?matchOnUriPrefix=true" />
+  <to uri="cxfbean:apiKeyService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+   <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService2.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService2.route
new file mode 100644
index 0000000..e4a46d6
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/apiKeyService2.route
@@ -0,0 +1,9 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///apiKeys?matchOnUriPrefix=true" />
+  <to uri="cxfbean:apiKeyService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+   <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+		<removeHeader headerName="exception"/>
+  
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/errorMessage.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/errorMessage.route
new file mode 100644
index 0000000..7c08576
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/errorMessage.route
@@ -0,0 +1,4 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+    <from uri="servlet:/__module_ajsc_namespace_name__/__module_ajsc_namespace_version__/errorMessageLookupService2"/>
+    <to uri="bean:errorMessageLookupService?method=getExceptionDetails"/>
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/eventService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/eventService.route
new file mode 100644
index 0000000..54613c4
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/eventService.route
@@ -0,0 +1,15 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+ 
+
+  
+  <from uri="att-dme2-servlet:///events?matchOnUriPrefix=true" />
+  <to uri="cxfbean:eventService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+    <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+</route>
+
+ 
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloCAET.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloCAET.route
new file mode 100644
index 0000000..0c147a3
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloCAET.route
@@ -0,0 +1,43 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+    
+	<onException>
+		<exception>java.lang.Throwable</exception>
+		
+		<setHeader headerName="AJSC_CAET_ERRORCODE">
+			<constant>CD-0001</constant>
+		</setHeader>
+		<setHeader headerName="AJSC_CAET_APPID">
+			<constant>AJSC</constant>
+		</setHeader>
+		<setHeader headerName="AJSC_CAET_MESSAGE_TEXT">
+			<constant>Unable to retrive client details</constant>
+		</setHeader>
+		<setHeader headerName="AJSC_CAET_IS_REST_SERVICE">
+			<constant>Y</constant>
+		</setHeader>
+		<setHeader headerName="X-CSI-ClientApp">
+			<constant>AJSC-CSI</constant>
+		</setHeader>	
+		<setHeader headerName="CALL_TYPE">
+			<constant>GATEWAY</constant>
+		</setHeader>			
+						
+    	<to uri="bean:errorMessageLookupService?method=setCAETHeaders"/>
+
+		<removeHeaders pattern="AJSC_CAET*"/>
+		
+		<handled>
+			<constant>true</constant>
+		</handled>
+	</onException>
+  	
+    <from uri="restlet:/__module_ajsc_namespace_name__/__module_ajsc_namespace_version__/helloCAET"/>
+    
+
+	<convertBodyTo type="java.lang.String"/>
+	<setBody>
+		<groovy>
+			throw new Exception("new Change")
+		</groovy>
+	</setBody>
+	</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloServlet.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloServlet.route
new file mode 100644
index 0000000..5ede9c1
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloServlet.route
@@ -0,0 +1,4 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+     <from uri="servlet:///__module_ajsc_namespace_name__/__module_ajsc_namespace_version__/helloServlet?matchOnUriPrefix=true" />
+   	 <to uri="bean:helloWorld?method=speak"/>
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloWorld.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloWorld.route
new file mode 100644
index 0000000..bc3e178
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/helloWorld.route
@@ -0,0 +1,4 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+    <from uri="restlet:/__module_ajsc_namespace_name__/__module_ajsc_namespace_version__/helloWorld"/>
+    <to uri="bean:helloWorld?method=speak"/>
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/metricsService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/metricsService.route
new file mode 100644
index 0000000..704a452
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/metricsService.route
@@ -0,0 +1,9 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///metrics?matchOnUriPrefix=true" />
+  <to uri="cxfbean:metricsService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+    <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+</route>
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/mirrorService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/mirrorService.route
new file mode 100644
index 0000000..238f54d
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/mirrorService.route
@@ -0,0 +1,15 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+ 
+
+  
+  <from uri="att-dme2-servlet:///mirrormakers?matchOnUriPrefix=true" />
+  <to uri="cxfbean:mirrorService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+    <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+</route>
+
+ 
\ No newline at end of file
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/topicService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/topicService.route
new file mode 100644
index 0000000..eddace7
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/topicService.route
@@ -0,0 +1,19 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true" >
+  
+  <from uri="att-dme2-servlet:///topics?matchOnUriPrefix=true" />
+	
+  <to uri="cxfbean:topicService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+
+     <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+  
+<log message="Body= ** ${body}" loggingLevel="DEBUG" logName="com.att.nsa.dmaap"/>
+<log message="Body= ** ${body}" loggingLevel="DEBUG" logName="com.att.nsa.dmaap.service"/>
+
+</route>
+
+
+
diff --git a/src/main/ajsc/dmaap_v1/dmaap/v1/routes/transactionService.route b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/transactionService.route
new file mode 100644
index 0000000..8b043fc
--- /dev/null
+++ b/src/main/ajsc/dmaap_v1/dmaap/v1/routes/transactionService.route
@@ -0,0 +1,9 @@
+<route xmlns="http://camel.apache.org/schema/spring" trace="true">
+  <from uri="att-dme2-servlet:///transaction?matchOnUriPrefix=true" />
+  <to uri="cxfbean:transactionService?providers=#jacksonProvider,#cambriaExMapper,#webExMapper" />
+    <setBody>
+		<simple>${in.header.exception}</simple>
+	</setBody> 
+	
+	<removeHeader headerName="exception"/>
+</route>
\ No newline at end of file