camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raghu35 <raghavendra.agarw...@gmail.com>
Subject from restlet to activemq
Date Fri, 03 Oct 2014 12:38:33 GMT
hi, 

I am a beginner so please excuse the ignorance bit. 

What I am trying to do .
1. Hit a URL with params.
2. Make a HashMap and submit the same into ActiveMQ. 

My camel-context.xml is as follows:
<?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"
	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">
	<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="restlet:http://localhost:8080/resttest/{request}"/>
        <log message="Inside of message to get surname"/>
        <bean method="transform" ref="myTransform"/>
        <log message="Got surname - ${body}"/>
        <to uri="jms:topic:brokerURL" />
    </route>
</camelContext>
	<bean id="myTransform" class="com.mycompany.camel.spring.MyTransform">
		<property name="prefix" value="${prefix}" />
	</bean>
     <bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616" />
    </bean>
</beans>

My error is as follows:
Post I hit the url i.e.
http://localhost:8080/resttest/msisdn=999&name=raghu&channel=wap

The error message is as follows:
org.apache.camel.ExchangeTimedOutException: The OUT message was not received
within: 20000 millis due reply message with correlationID:
Camel-ID-Raghus-MacBook-Pro-local-55919-1412338618867-0-6 not received.
Exchange[Message: {msisdn=999, name=raghu, channel=wap}]
	at
org.apache.camel.component.jms.reply.ReplyManagerSupport.processReply(ReplyManagerSupport.java:133)
	at
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler.onTimeout(TemporaryQueueReplyHandler.java:61)
	at
org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:53)
	at
org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:30)
	at
org.apache.camel.support.DefaultTimeoutMap.purge(DefaultTimeoutMap.java:209)
	at
org.apache.camel.support.DefaultTimeoutMap.run(DefaultTimeoutMap.java:159)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:744)



--
View this message in context: http://camel.465427.n5.nabble.com/from-restlet-to-activemq-tp5757338.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message