Hi I am trying to move contents of one queue to another queue. The source queue contains Java object.
My came route 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:amq="http://activemq.apache.org/schema/core"; 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://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd";> <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"> <property name="brokerURL" value="failover:tcp://localhost:61620" /> <property name="userName" value="admin" /> <property name="password" value="admin" /> </bean> <camelContext xmlns="http://camel.apache.org/schema/spring";> <route> <from uri="activemq:OBJECT.QUEUE2" /> <to uri="activemq:OBJECT.QUEUE3" /> </route> </camelContext> </beans>* It OBJECT.QUEUE1 contains an object of class Student. * Student.java Class ------------- package com.queueshifter.camel.activemq.queueshifter; import java.io.Serializable; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlAttribute; import javax.xml.bind.annotation.XmlElement; import javax.xml.bind.annotation.XmlRootElement; @XmlAccessorType @XmlRootElement public class Student implements Serializable{ //@XmlElement String name; //@XmlElement int rollNo; public String getName() { return name; } public void setName(String name) { this.name = name; } public int getRollNo() { return rollNo; } public void setRollNo(int rollNo) { this.rollNo = rollNo; } } * I get following error while running the routes. Any ideas will be very helpful Cheers Reji * [0 - JmsConsumer[OBJECT.QUEUE2]] EndpointMessageListener WARN Execution of JMS message listener failed. Caused by: [org.apache.camel.RuntimeCamelException - Failed to extract body due to: javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: com.poc.camel.jaxb.Student. Message: ActiveMQObjectMessage {commandId = 7, responseRequired = true, messageId = ID:D-113043114-56208-1389845707678-3:1:1:1:3, originalDestination = queue://OBJECT.QUEUE, originalTransactionId = null, producerId = ID:D-113043114-56208-1389845707678-3:1:1:1, destination = queue://OBJECT.QUEUE2, transactionId = null, expiration = 0, timestamp = 1389845710753, arrival = 0, brokerInTime = 1389851883384, brokerOutTime = 1389851883384, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@12cd7ba, marshalledProperties = org.apache.activemq.util.ByteSequence@106fe2b, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {firedTime=Thu Jan 16 09:45:09 IST 2014, breadcrumbId=ID-D-113043114-56207-1389845706616-0-1, CamelJmsDeliveryMode=2}, readOnlyProperties = true, readOnlyBody = true, droppable = false}] org.apache.camel.RuntimeCamelException: Failed to extract body due to: javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: com.poc.camel.jaxb.Student. Message: ActiveMQObjectMessage {commandId = 7, responseRequired = true, messageId = ID:D-113043114-56208-1389845707678-3:1:1:1:3, originalDestination = queue://OBJECT.QUEUE, originalTransactionId = null, producerId = ID:D-113043114-56208-1389845707678-3:1:1:1, destination = queue://OBJECT.QUEUE2, transactionId = null, expiration = 0, timestamp = 1389845710753, arrival = 0, brokerInTime = 1389851883384, brokerOutTime = 1389851883384, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@12cd7ba, marshalledProperties = org.apache.activemq.util.ByteSequence@106fe2b, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {firedTime=Thu Jan 16 09:45:09 IST 2014, breadcrumbId=ID-D-113043114-56207-1389845706616-0-1, CamelJmsDeliveryMode=2}, readOnlyProperties = true, readOnlyBody = true, droppable = false} at org.apache.camel.component.jms.JmsBinding.extractBodyFromJms(JmsBinding.java:150)[camel-jms-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.component.jms.JmsMessage.createBody(JmsMessage.java:214)[camel-jms-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:41)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.impl.DefaultUnitOfWork.<init>(DefaultUnitOfWork.java:88)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.impl.DefaultUnitOfWork.<init>(DefaultUnitOfWork.java:71)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.UnitOfWorkProcessor.createUnitOfWork(UnitOfWorkProcessor.java:190)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:104)[camel-jms-2.10.0.fuse-71-047.jar:2.10.0.fuse-71-047] at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[spring-jms-3.0.7.RELEASE.jar:3.0.7.RELEASE] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)[:1.7.0_45] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)[:1.7.0_45] at java.lang.Thread.run(Unknown Source)[:1.7.0_45] * -- View this message in context: http://camel.465427.n5.nabble.com/Moving-Objects-between-Active-MQ-queues-using-Camel-Routes-tp5746020.html Sent from the Camel - Users mailing list archive at Nabble.com.
