<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>2.10.0.redhat-60024</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>2.10.0.redhat-60024</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-security-cors</artifactId>
<version>2.6.1</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>3.1.3.RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-cxf</artifactId>
<version>2.10.0.redhat-60024</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http-jetty</artifactId>
<version>2.6.0.redhat-60024</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-extension-providers</artifactId>
<version>2.6.1</version>
</dependency>
<dependency>
<groupId>org.codehaus.jettison</groupId>
<artifactId>jettison</artifactId>
<version>1.3.1</version>
</dependency>
Service:
@POST
@Path("/ADDACLAssociate")
@Consumes("application/json")
public Response addACLAssociate(@QueryParam("id") String
id,@QueryParam("emp") String name,Associate ass)
{
return Response.ok( "success").build();
}
My pojo:
import java.io.Serializable;
public class Associate implements Serializable
{
String id;
public String getId()
{
return id;
}
public void setId( String id )
{
this.id = id;
}
}
application context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:cxf="http://camel.apache.org/schema/cxf"
xmlns:jaxrs="http://cxf.apache.org/jaxrs"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
http://camel.apache.org/schema/cxf
http://camel.apache.org/schema/cxf/camel-cxf.xsd
http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd">
<bean id="myDb" class="com.mongodb.Mongo">
<constructor-arg index="0" value="localhost"/>
</bean>
<bean id="associate"
class="com.dstsystems.dstfsrc.acl.routes.AccessControlAssociate"/>
<bean id="cxfJaxrsJsonProvider"
class="org.apache.cxf.jaxrs.provider.json.JSONProvider" />
<bean id="restResource"
class="com.dstsystems.dstfsrc.acl.routes.AccessControlServices" />
<jaxrs:server id="restService" staticSubresourceResolution="true">
<jaxrs:serviceBeans>
<ref bean="restResource" />
</jaxrs:serviceBeans>
<jaxrs:providers>
<ref bean="cxfJaxrsJsonProvider" />
</jaxrs:providers>
</jaxrs:server>
<cxf:rsServer id="service" address="/rest/fsrc"
serviceClass="com.dstsystems.dstfsrc.acl.routes.AccessControlServices"
loggingFeatureEnabled="true">
<cxf:providers>
<bean
class="org.apache.cxf.rs.security.cors.CrossOriginResourceSharingFilter" />
</cxf:providers>
</cxf:rsServer>
<camelContext trace="false" id="AccessControl-Routes"
xmlns="http://camel.apache.org/schema/spring">
<propertyPlaceholder location="classpath:sql.properties"
id="placeholder"/>
<route id="MongoDB-AccessControlRoute1">
<from
uri="cxfrs:http://localhost:8096/rest?resourceClasses=com.dstsystems.dstfsrc.acl.routes.AccessControlServices"/>
<choice>
<when>
<simple>${in.header.operationName} ==
'getACLAssociate'</simple>
<log message="${in.header.operationName}"/>
<to uri="bean:associate"/>
<log message="${body}"/>
<to
uri="mongodb:myDb?database=dstfsrc&collection=accesscontrollist&operation=insert"/>
</when>
<when>
<simple>${in.header.operationName} ==
'getACLAssociates'</simple>
<log message="${in.header.operationName}"/>
<to uri="bean:associate?method=processACLAssociates"/>
<log message="${body}"/>
<to
uri="mongodb:myDb?database=dstfsrc&collection=accesscontrollist&operation=insert"/>
</when>
<when>
<simple>${in.header.operationName} ==
'removeACLAssociate'</simple>
<log message="${in.header.operationName}"/>
<to uri="bean:associate?method=removeACLAssociate"/>
<log message="${in.header.operationName}"/>
<to
uri="mongodb:myDb?database=dstfsrc&collection=accesscontrollist&operation=remove"/>
</when>
<when>
<simple>${in.header.operationName} ==
'addACLAssociate'</simple>
<log message="${in.header.operationName}"/>
<to uri="bean:associate?method=addACLAssociate"/>
<log message="${in.header.operationName}"/>
<to
uri="mongodb:myDb?database=dstfsrc&collection=accesscontrollist&operation=update"/>
<to uri="bean:associate?method=updateACLAssociate"/>
</when>
<otherwise>
<log message="${in.header.CamelHttpPath}"/>
<transform>
<constant>No EAD Mongo resource found for URI</constant>
</transform>
</otherwise>
</choice>
</route>
</camelContext>
</beans>
Iam new camel rotes development.Iam strucked at here from last two
days.Please help me on it
--
View this message in context:
http://camel.465427.n5.nabble.com/Getting-NO-Messege-Reader-Exception-Please-give-me-the-direction-to-move-forward-tp5774995p5774996.html
Sent from the Camel - Users mailing list archive at Nabble.com.