Hello.
Can you please help me figure out why camel 2.0 JMS options on
http://camel.apache.org/jms.html this page (the highlighted) are not
working in my project ?
I tried jmsMessageType , jmsKeyFormatStrategy and few others.
This is how I configure my endpoint:
ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("failover:(discovery:(multicast://default),tcp://localhost:61616)");
getCamelcontext().addComponent("AMQComponent1",
JmsComponent.jmsComponent(connectionFactory));
My route:
from("AMQComponent1:queue:QClientToServer?concurrentConsumers=2&jmsMessageType=Text").to("seda:a");
I have this in my POM:
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jms</artifactId>
<version>2.0-M1</version>
<scope>compile</scope>
</dependency>
dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>2.0-M1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jaxb</artifactId>
<version>2.0-M1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.2.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-camel</artifactId>
<version>5.2.0</version>
<scope>compile</scope>
</dependency>
I get the following exception:
INFO DefaultCamelContext:729 - Apache Camel 2.0-M1 (CamelContext:camel-1) is
starting
Exception in thread "main" org.apache.camel.ResolveEndpointFailedException:
Failed to resolve endpoint:
AMQComponent1:queue:QClientToServer?concurrentConsumers=2&jmsMessageType=Text
due to: org.apache.camel.ResolveEndpointFailedException: Failed to resolve
endpoint:
AMQComponent1:queue:QClientToServer?concurrentConsumers=2&jmsMessageType=Text
due to: There are 1 parameters that couldn't be set on the endpoint. Check
the uri if the parameters are spelt correctly and that they are properties
of the endpoint. Unknown parameters=[{jmsMessageType=Text}]
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:378)
at
org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:52)
at
org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:133)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:103)
at
org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:109)
at
org.apache.camel.model.FromDefinition.resolveEndpoint(FromDefinition.java:72)
at
org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:78)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:302)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:121)
at
org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:481)
at
org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:777)
at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:759)
at
org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:50)
...
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
AMQComponent1:queue:QClientToServer?concurrentConsumers=2&jmsMessageType=Text
due to: There are 1 parameters that couldn't be set on the endpoint. Check
the uri if the parameters are spelt correctly and that they are properties
of the endpoint. Unknown parameters=[{jmsMessageType=Text}]
at
org.apache.camel.impl.DefaultComponent.validateParameters(DefaultComponent.java:115)
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:93)
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:359)
... 13 more
Regards.
Eric.
--
View this message in context:
http://www.nabble.com/Camel-2.0-JMS-options-are-not-working-tp23801797p23801797.html
Sent from the Camel - Users mailing list archive at Nabble.com.
