<rest path="restservices/sapmp/v1/cart/">
            <post uri="/addCart">
                <to uri="direct:addCart" />
             </post>

public void subscriberServiceRoute() {

  	ajscRoute.setRoute(from("restlet:/subscriber/subscribernotifications?restletMethods=POST&restletBinding=#customBinding")
	.log("************ Determine the event type ************")
    	.choice()
	.when().simple("${body} =~ '" + SubscriberConstants.CANCEL_SUBSCRIBER + "'").to("direct:cancelSubscriber")
}

<delete uri="/order/modify/modifyOrder">
                <to uri="direct:modifyOrder" />            
</delete>

<put uri="/order/modify/modifyOrder">
                <to uri="direct:modifyOrder" />            
</put>

<from uri="direct:submitOrder" />
	<to uri="direct:fanAuthorization" />

public void unenroll()
{
  	from("direct:unenrollSubscriber")
  	.process("prepareInputToUnEnroll")
  	.to("invokeUnenrollService")
        .log("Unenroll Service Status Code in MobileSplit :: ${in.headers.CamelHttpResponseCode}")
        .choice()
        .when().simple("${in.headers.CamelHttpResponseCode} =~ "+ "'"+SubscriberConstants.RESPONSE_SUCCESS_CODE+"'"
          + " || ${in.headers.CamelHttpResponseCode} =~ '"+SubscriberConstants.ACCEPTED_CODE+"'")
           .to("direct:retireRecord")
           .process(SubscriberConstants.RESPONSE_HANDLER)
        .otherwise()
             .setBody().constant(SubscriberConstants.MESSAGE_UNENROLLMENT_UNSUCCESSFUL)
             .process(SubscriberConstants.RESPONSE_ERROR_HANDLER)
        .endChoice().end(); 
}

public void configure() throws Exception {
	from("seda:largeListConsumer?concurrentConsumers=1&size=1000&timeout=0&blockWhenFull=true")
                .routeId("largeListConsumer")
                .to("direct:processFile")
                .end();
}

<from id="_from1" uri="restlet:/addp/v1/account/profiles?restletMethods=POST&restletBinding=#customBinding"/>
        <doTry id="_doTrymp">
            <to id="_to_MAN1" uri="bean:restServiceImpl?method=manageProfile"/>
            <process id="_manageProfileService" ref="manageProfileService"/>

public void subscriberServiceRoute()
{
  	ajscRoute.setRoute(from("restlet:/subscriber/subscribernotifications?restletMethods=POST&restletBinding=#customBinding")
  	  .bean("SubscriberNotificationBeans","getSubscriberNotifications(exchange)")
 	  .process("decideEventType"));
}

<from uri="direct:submitOrder" />
  <interceptFrom id="_interceptFrom2">
   	<to id="submitOrderCamelInterceptor" uri="bean:camelInterceptor?method=invokepreInterceptorChain" />
  </interceptFrom>

<from id="_from_D4" uri="direct:fanAuthorization" />
  <process ref="prepareProfileInputData" />

public void cancelSubscriber() {
    from("direct:cancelSubscriber").process("prepareInputToAddpDeviceDetails") 
                                       .bean("inquireEnterpriseDeviceDeploymentDetails", "inquireDeviceDetailsByCtn(${body})");
}

<from uri="restlet:/user?restletMethod=POST"/>
          <setBody>
                <simple>select * from user ORDER BY id desc LIMIT 1</simple>
            </setBody>
            <to uri="jdbc:dataSource"/>        

<route id="createUser">
            <from uri="restlet:/user?restletMethod=POST"/>
            <setBody>
                <simple>insert into user(firstName, lastName) values('${header.firstName}','${header.lastName}');  
                    CALL IDENTITY();               
  		</simple>
            </setBody>
            <to uri="jdbc:dataSource"/>

public void configure() {
    from("restlet:/user?restletMethod=POST")
	.setBody(simple("select * from user ORDER BY id desc LIMIT 1"))
        .to("jdbc:dataSource");
}

public void configure() {  
   from("restlet:/user/{userId}?restletMethods=GET,PUT,DELETE")
	 .setBody(simple("update user set firstName='${header.firstName}', lastName='${header.lastName}' where id = ${header.userId}"))
         .to("jdbc:dataSource"); 
}

public void configure() throws Exception 
{
   from("jms:JmsQueue").bean(ProcessingBean.class, "doSomething").to("jms:redirected");
}

<route id="fileRoute2">
	<from uri="file:home/customers/new?fileName=new.xml"/>
    <to uri="file://home/customers/old"/>
</route>

public void configure() throws Exception {
	from("file:home/customers/old")
                .routeId("transfer")
				.log(LoggingLevel.INFO, "com.toyota.tme.cws.transform.route.error", "Transferring File - ${file:name}")
                .to("file:home/customers/new")
                .end();
}

public void configure () throws Exception {
	from("file://inputdir?fileName=order.xml")
                .routeId("readFilefromDir")
				.log(LoggingLevel.INFO, "com.toyota.tme.cws.transform.route.error", "Processing File - ${file:name}")
                .bean("FileBusiness", "moveToSedaQueue")
                .end();
}

public void configure () throws Exception {
	from("direct:start")       
            .to("kafka:localhost:8080?topic=testkafkaprod3");
}

public void configure () throws Exception {
	from("kafka:localhost:8080?topic=testkafkacon1&zookeeperHost=localhost&zookeeperPort=2181&groupId=group1").to("file:input");
}