You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@camel.apache.org by Gnanaguru S <gn...@wipro.com> on 2011/10/17 14:08:05 UTC

Specifying different destinations using camel

Hi 

I have this scenario.

I have three ActiveMQ brokers at different, I am using camels loadbalancing
capability to avail HA. Below is my code:

<?xml version="1.0" encoding="UTF-8"?>
<blueprint
     xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="
       http://www.osgi.org/xmlns/blueprint/v1.0.0
       http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
     <camelContext xmlns="http://camel.apache.org/schema/blueprint"
trace="true">
	     

	   
	    <route>
    <from uri="file://inputdir/"/>

    <loadBalance>
        <roundRobin/>
       * <to uri="HOST1:activemq:queue:test"/> 
        <to uri="HOST2:activemq:queue:test"/>
        <to uri="HOST3:activemq:queue:test"/>*
    </loadBalance>
  </route>

	    
     </camelContext>
</blueprint> 

As the lines marked in bold, I want to route to different brokers in
roundrobin fashion. But i dont know how to specify different broker address
in camel. 

please help me out. 

Such that i can achieve high availability through camel and AMQ.

Hope my question was clear. 


Regards
Guru


--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909674.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

Ok. Let me check this load balance by generating some random messages. 
Using camel can i generate 1000 messages ?. How ?. Such that I will test it
for load balancer . 


Regards
Guru

--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909902.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

Hi Claus,

The stacktrace was a older one, Since even though i changed my route code.
Still SMX is running cached code. 

i did restart bundleid . and now its working good. Load balancing was done
well using camel.

Thanks for inventing camel claus. Since with it i am learning middleware
scenario in a easier way.

Cheers
Guru

--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4910096.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Claus Ibsen <cl...@gmail.com>.

Hi

You do a XSLT transformation
xslt://file:C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\design.xsl

Make sure the content is XML.



On Mon, Oct 17, 2011 at 3:10 PM, Gnanaguru S
<gn...@wipro.com> wrote:
>
> I dont understand claus,
>
> How can i get all the files without any loss. Is there anyother algorithm
> other than roundrobin ?.
>
>
> Regards
> Guru
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909821.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

I dont understand claus,

How can i get all the files without any loss. Is there anyother algorithm
other than roundrobin ?.


Regards
Guru

--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909821.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Claus Ibsen <cl...@gmail.com>.

The exception in the stacktrace is because you do some XML
transformation or the likes, but the content in the files is not XML.


On Mon, Oct 17, 2011 at 3:05 PM, Gnanaguru S
<gn...@wipro.com> wrote:
>
> Sorry , My mind was totally blocked.
>
>
> For the program in the previous post,
>
> If i put four text files in inputdir, I am getting only two at my outputdir
> .
>
> This is my log from smx.
>
> 18:30:24,613 | INFO  | file://inputdir/ | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID-D-183913-4721-1318851250282-0-132 >>> (route3) from(file://inputdir/) -->
> activemq://queue:inputQueue <<< Pattern:InOnly,
> Headers:{CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
> CamelFileRelativePath=4.txt, CamelFileLength=376, CamelFileNameOnly=4.txt,
> CamelFileName=4.txt, CamelFileParent=inputdir,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
> CamelFileAbsolute=false, CamelFilePath=inputdir\4.txt},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:##########################################################
> ##########################################################
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##                     Mail From Prajod !               ##
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##########################################################
> ##########################################################
> 18:30:24,629 | INFO  | umer[inputQueue] | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID:D-183913-4725-1318851260844-4:11:1:1:2 >>> (route4)
> from(activemq://queue:inputQueue) -->
> xslt://file:C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\design.xsl
> <<< Pattern:InOnly, Headers:{CamelFileRelativePath=4.txt,
> CamelFileAbsolute=false, CamelFileParent=inputdir, CamelFileLastModified=Mon
> Oct 10 16:28:05 IST 2011, JMSExpiration=0, JMSXGroupID=null,
> JMSCorrelationID=null, JMSTimestamp=1318856424629,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
> JMSType=null, JMSRedelivered=false, CamelFileNameOnly=4.txt,
> CamelFileName=4.txt, CamelFilePath=inputdir\4.txt,
> JMSMessageID=ID:D-183913-4725-1318851260844-4:11:1:1:2, CamelFileLength=376,
> JMSDestination=queue://inputQueue, JMSDeliveryMode=2, JMSReplyTo=null,
> JMSPriority=4}, BodyType:byte[],
> Body:##########################################################
> ##########################################################
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##                     Mail From Prajod !               ##
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##                                                      ##
> ##########################################################
> ##########################################################
> 18:30:24,644 | ERROR | umer[inputQueue] | DefaultErrorHandler              |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
> exchangeId: ID:D-183913-4725-1318851260844-4:11:1:1:2. Exhausted after
> delivery attempt: 1 caught: javax.xml.transform.TransformerException:
> Content is not allowed in prolog.
> javax.xml.transform.TransformerException: Content is not allowed in prolog.
>        at
> org.apache.xalan.transformer.TransformerImpl.fatalError(TransformerImpl.java:780)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:756)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1273)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1251)[:]
>        at
> org.apache.camel.builder.xml.XsltBuilder.process(XsltBuilder.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:125)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:106)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:85)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:93)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
>        at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
> 18:30:24,644 | WARN  | umer[inputQueue] | JmsMessageListenerContainer      |
> 93 - org.springframework.jms - 3.0.5.RELEASE | Execution of JMS message
> listener failed, and no ErrorHandler has been set.
> org.apache.camel.RuntimeCamelException:
> javax.xml.transform.TransformerException: Content is not allowed in prolog.
>        at
> org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1139)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:122)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
>        at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
> Caused by: javax.xml.transform.TransformerException: Content is not allowed
> in prolog.
>        at
> org.apache.xalan.transformer.TransformerImpl.fatalError(TransformerImpl.java:780)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:756)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1273)[:]
>        at
> org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1251)[:]
>        at
> org.apache.camel.builder.xml.XsltBuilder.process(XsltBuilder.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:125)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:106)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:85)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:93)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        ... 11 more
> 18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID-D-183913-4721-1318851250282-14-6 >>> (route34) from(file://inputdir/) -->
> activemq1:queue:ClusterTest, activemq2:queue:ClusterTest <<< Pattern:InOnly,
> Headers:{CamelFileName=3.txt, CamelFileLength=376,
> CamelFileRelativePath=3.txt, CamelFileAbsolute=false,
> CamelFileParent=inputdir, CamelFileLastModified=Mon Oct 10 16:28:05 IST
> 2011, CamelFileNameOnly=3.txt,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\3.txt,
> CamelFilePath=inputdir\3.txt},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:GenericFile[3.txt]
> 18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID-D-183913-4721-1318851250282-14-6 >>> (route34)
> activemq1:queue:ClusterTest, activemq2:queue:ClusterTest -->
> activemq1://queue:ClusterTest <<< Pattern:InOnly,
> Headers:{CamelFileName=3.txt, CamelFileLength=376,
> CamelFileRelativePath=3.txt, CamelFileAbsolute=false,
> CamelFileParent=inputdir, CamelFileLastModified=Mon Oct 10 16:28:05 IST
> 2011, CamelFileNameOnly=3.txt,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\3.txt,
> CamelFilePath=inputdir\3.txt},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:GenericFile[3.txt]
> 18:30:24,816 | ERROR | file://inputdir/ | DefaultErrorHandler              |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
> exchangeId: ID-D-183913-4721-1318851250282-14-6. Exhausted after delivery
> attempt: 1 caught: java.lang.NullPointerException
> java.lang.NullPointerException
>        at java.io.FilterOutputStream.write(FilterOutputStream.java:80)[:1.6.0_17]
>        at
> org.apache.activemq.command.ActiveMQBytesMessage.writeBytes(ActiveMQBytesMessage.java:687)[46:org.apache.activemq.activemq-core:5.5.0.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.createJmsMessageForType(JmsBinding.java:516)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:459)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:281)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer$2.createMessage(JmsProducer.java:223)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:196)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:139)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$3.doInJms(JmsConfiguration.java:173)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:170)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:355)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:309)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:99)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:44)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_17]
>        at
> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_17]
>        at
> java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:181)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
>        at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
> 18:30:24,816 | WARN  | file://inputdir/ | GenericFileOnCompletion          |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Rollback file
> strategy:
> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@125b009
> for file: GenericFile[3.txt]
> 18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID-D-183913-4721-1318851250282-14-8 >>> (route34) from(file://inputdir/) -->
> activemq1:queue:ClusterTest, activemq2:queue:ClusterTest <<< Pattern:InOnly,
> Headers:{CamelFileRelativePath=4.txt, CamelFileParent=inputdir,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
> CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
> CamelFilePath=inputdir\4.txt, CamelFileName=4.txt, CamelFileLength=376,
> CamelFileNameOnly=4.txt, CamelFileAbsolute=false},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:GenericFile[4.txt]
> 18:30:24,832 | INFO  | file://inputdir/ | Tracer                           |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
> ID-D-183913-4721-1318851250282-14-8 >>> (route34)
> activemq1:queue:ClusterTest, activemq2:queue:ClusterTest -->
> activemq2://queue:ClusterTest <<< Pattern:InOnly,
> Headers:{CamelFileRelativePath=4.txt, CamelFileParent=inputdir,
> CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
> CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
> CamelFilePath=inputdir\4.txt, CamelFileName=4.txt, CamelFileLength=376,
> CamelFileNameOnly=4.txt, CamelFileAbsolute=false},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:GenericFile[4.txt]
> 18:30:24,832 | ERROR | file://inputdir/ | DefaultErrorHandler              |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
> exchangeId: ID-D-183913-4721-1318851250282-14-8. Exhausted after delivery
> attempt: 1 caught: java.lang.NullPointerException
> java.lang.NullPointerException
>        at java.io.FilterOutputStream.write(FilterOutputStream.java:80)[:1.6.0_17]
>        at
> org.apache.activemq.command.ActiveMQBytesMessage.writeBytes(ActiveMQBytesMessage.java:687)[46:org.apache.activemq.activemq-core:5.5.0.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.createJmsMessageForType(JmsBinding.java:516)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:459)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:281)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer$2.createMessage(JmsProducer.java:223)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:196)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:139)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$3.doInJms(JmsConfiguration.java:173)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[93:org.springframework.jms:3.0.5.RELEASE]
>        at
> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:170)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:355)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:309)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:99)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:44)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
>        at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_17]
>        at
> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_17]
>        at
> java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:181)[:1.6.0_17]
>        at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
>        at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
>        at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
> 18:30:24,832 | WARN  | file://inputdir/ | GenericFileOnCompletion          |
> 78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Rollback file
> strategy:
> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@125b009
> for file: GenericFile[4.txt]
>
>
> Regards
> Guru
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909813.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

Sorry , My mind was totally blocked.
 

For the program in the previous post, 

If i put four text files in inputdir, I am getting only two at my outputdir
. 

This is my log from smx.

18:30:24,613 | INFO  | file://inputdir/ | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID-D-183913-4721-1318851250282-0-132 >>> (route3) from(file://inputdir/) -->
activemq://queue:inputQueue <<< Pattern:InOnly,
Headers:{CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
CamelFileRelativePath=4.txt, CamelFileLength=376, CamelFileNameOnly=4.txt,
CamelFileName=4.txt, CamelFileParent=inputdir,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
CamelFileAbsolute=false, CamelFilePath=inputdir\4.txt},
BodyType:org.apache.camel.component.file.GenericFile,
Body:##########################################################
##########################################################
##							##
##							##
##							##
##                     Mail From Prajod !		##
##							##
##							##
##							##
##							##
##########################################################
##########################################################
18:30:24,629 | INFO  | umer[inputQueue] | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID:D-183913-4725-1318851260844-4:11:1:1:2 >>> (route4)
from(activemq://queue:inputQueue) -->
xslt://file:C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\design.xsl
<<< Pattern:InOnly, Headers:{CamelFileRelativePath=4.txt,
CamelFileAbsolute=false, CamelFileParent=inputdir, CamelFileLastModified=Mon
Oct 10 16:28:05 IST 2011, JMSExpiration=0, JMSXGroupID=null,
JMSCorrelationID=null, JMSTimestamp=1318856424629,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
JMSType=null, JMSRedelivered=false, CamelFileNameOnly=4.txt,
CamelFileName=4.txt, CamelFilePath=inputdir\4.txt,
JMSMessageID=ID:D-183913-4725-1318851260844-4:11:1:1:2, CamelFileLength=376,
JMSDestination=queue://inputQueue, JMSDeliveryMode=2, JMSReplyTo=null,
JMSPriority=4}, BodyType:byte[],
Body:##########################################################
##########################################################
##							##
##							##
##							##
##                     Mail From Prajod !		##
##							##
##							##
##							##
##							##
##########################################################
##########################################################
18:30:24,644 | ERROR | umer[inputQueue] | DefaultErrorHandler              |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
exchangeId: ID:D-183913-4725-1318851260844-4:11:1:1:2. Exhausted after
delivery attempt: 1 caught: javax.xml.transform.TransformerException:
Content is not allowed in prolog.
javax.xml.transform.TransformerException: Content is not allowed in prolog.
	at
org.apache.xalan.transformer.TransformerImpl.fatalError(TransformerImpl.java:780)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:756)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1273)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1251)[:]
	at
org.apache.camel.builder.xml.XsltBuilder.process(XsltBuilder.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.Pipeline.process(Pipeline.java:125)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:106)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:85)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:93)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[93:org.springframework.jms:3.0.5.RELEASE]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
	at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
18:30:24,644 | WARN  | umer[inputQueue] | JmsMessageListenerContainer      |
93 - org.springframework.jms - 3.0.5.RELEASE | Execution of JMS message
listener failed, and no ErrorHandler has been set.
org.apache.camel.RuntimeCamelException:
javax.xml.transform.TransformerException: Content is not allowed in prolog.
	at
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1139)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:122)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[93:org.springframework.jms:3.0.5.RELEASE]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
	at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
Caused by: javax.xml.transform.TransformerException: Content is not allowed
in prolog.
	at
org.apache.xalan.transformer.TransformerImpl.fatalError(TransformerImpl.java:780)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:756)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1273)[:]
	at
org.apache.xalan.transformer.TransformerImpl.transform(TransformerImpl.java:1251)[:]
	at
org.apache.camel.builder.xml.XsltBuilder.process(XsltBuilder.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.Pipeline.process(Pipeline.java:125)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:106)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:85)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:93)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	... 11 more
18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID-D-183913-4721-1318851250282-14-6 >>> (route34) from(file://inputdir/) -->
activemq1:queue:ClusterTest, activemq2:queue:ClusterTest <<< Pattern:InOnly,
Headers:{CamelFileName=3.txt, CamelFileLength=376,
CamelFileRelativePath=3.txt, CamelFileAbsolute=false,
CamelFileParent=inputdir, CamelFileLastModified=Mon Oct 10 16:28:05 IST
2011, CamelFileNameOnly=3.txt,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\3.txt,
CamelFilePath=inputdir\3.txt},
BodyType:org.apache.camel.component.file.GenericFile,
Body:GenericFile[3.txt]
18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID-D-183913-4721-1318851250282-14-6 >>> (route34)
activemq1:queue:ClusterTest, activemq2:queue:ClusterTest -->
activemq1://queue:ClusterTest <<< Pattern:InOnly,
Headers:{CamelFileName=3.txt, CamelFileLength=376,
CamelFileRelativePath=3.txt, CamelFileAbsolute=false,
CamelFileParent=inputdir, CamelFileLastModified=Mon Oct 10 16:28:05 IST
2011, CamelFileNameOnly=3.txt,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\3.txt,
CamelFilePath=inputdir\3.txt},
BodyType:org.apache.camel.component.file.GenericFile,
Body:GenericFile[3.txt]
18:30:24,816 | ERROR | file://inputdir/ | DefaultErrorHandler              |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
exchangeId: ID-D-183913-4721-1318851250282-14-6. Exhausted after delivery
attempt: 1 caught: java.lang.NullPointerException
java.lang.NullPointerException
	at java.io.FilterOutputStream.write(FilterOutputStream.java:80)[:1.6.0_17]
	at
org.apache.activemq.command.ActiveMQBytesMessage.writeBytes(ActiveMQBytesMessage.java:687)[46:org.apache.activemq.activemq-core:5.5.0.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.createJmsMessageForType(JmsBinding.java:516)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:459)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:281)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer$2.createMessage(JmsProducer.java:223)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:196)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:139)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$3.doInJms(JmsConfiguration.java:173)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:170)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:355)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:309)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:99)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:44)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_17]
	at
java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_17]
	at
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:181)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
	at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
18:30:24,816 | WARN  | file://inputdir/ | GenericFileOnCompletion          |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Rollback file
strategy:
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@125b009
for file: GenericFile[3.txt]
18:30:24,816 | INFO  | file://inputdir/ | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID-D-183913-4721-1318851250282-14-8 >>> (route34) from(file://inputdir/) -->
activemq1:queue:ClusterTest, activemq2:queue:ClusterTest <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=4.txt, CamelFileParent=inputdir,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
CamelFilePath=inputdir\4.txt, CamelFileName=4.txt, CamelFileLength=376,
CamelFileNameOnly=4.txt, CamelFileAbsolute=false},
BodyType:org.apache.camel.component.file.GenericFile,
Body:GenericFile[4.txt]
18:30:24,832 | INFO  | file://inputdir/ | Tracer                           |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 |
ID-D-183913-4721-1318851250282-14-8 >>> (route34)
activemq1:queue:ClusterTest, activemq2:queue:ClusterTest -->
activemq2://queue:ClusterTest <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=4.txt, CamelFileParent=inputdir,
CamelFileAbsolutePath=C:\ESB\Fuse_ESB_4.4\apache-servicemix-4.4.0-fuse-00-27\inputdir\4.txt,
CamelFileLastModified=Mon Oct 10 16:28:05 IST 2011,
CamelFilePath=inputdir\4.txt, CamelFileName=4.txt, CamelFileLength=376,
CamelFileNameOnly=4.txt, CamelFileAbsolute=false},
BodyType:org.apache.camel.component.file.GenericFile,
Body:GenericFile[4.txt]
18:30:24,832 | ERROR | file://inputdir/ | DefaultErrorHandler              |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Failed delivery for
exchangeId: ID-D-183913-4721-1318851250282-14-8. Exhausted after delivery
attempt: 1 caught: java.lang.NullPointerException
java.lang.NullPointerException
	at java.io.FilterOutputStream.write(FilterOutputStream.java:80)[:1.6.0_17]
	at
org.apache.activemq.command.ActiveMQBytesMessage.writeBytes(ActiveMQBytesMessage.java:687)[46:org.apache.activemq.activemq-core:5.5.0.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.createJmsMessageForType(JmsBinding.java:516)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:459)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:281)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer$2.createMessage(JmsProducer.java:223)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.doSendToDestination(JmsConfiguration.java:196)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$100(JmsConfiguration.java:139)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$3.doInJms(JmsConfiguration.java:173)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[93:org.springframework.jms:3.0.5.RELEASE]
	at
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:170)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:355)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:309)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:99)[92:org.apache.camel.camel-jms:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:44)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:174)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:62)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:314)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:80)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)[78:org.apache.camel.camel-core:2.7.1.fuse-00-27]
	at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)[:1.6.0_17]
	at
java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)[:1.6.0_17]
	at
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:181)[:1.6.0_17]
	at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)[:1.6.0_17]
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)[:1.6.0_17]
	at java.lang.Thread.run(Thread.java:619)[:1.6.0_17]
18:30:24,832 | WARN  | file://inputdir/ | GenericFileOnCompletion          |
78 - org.apache.camel.camel-core - 2.7.1.fuse-00-27 | Rollback file
strategy:
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@125b009
for file: GenericFile[4.txt]


Regards
Guru

--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909813.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Claus Ibsen <cl...@gmail.com>.

On Mon, Oct 17, 2011 at 2:52 PM, Gnanaguru S
<gn...@wipro.com> wrote:
>
> Hi Claus, It worked . But I am missing indefinite number of files in the
> output directory.
>

What do you mean by "indefinite number of files .." ?


> <?xml version="1.0" encoding="UTF-8"?>
> <blueprint
>     xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
>     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>     xsi:schemaLocation="
>       http://www.osgi.org/xmlns/blueprint/v1.0.0
>       http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
>     <camelContext xmlns="http://camel.apache.org/schema/blueprint"
> trace="true">
>
>
>
>            <route>
>    <from uri="file://inputdir/"/>
>
>    <loadBalance>
>        <roundRobin/>
>
>        <to uri="activemq1:queue:ClusterTest"/>
>        <to uri="activemq2:queue:ClusterTest"/>
>
>    </loadBalance>
>  </route>
>
>         <route>
>                 <from uri="activemq1:queue:ClusterTest"/>
>                 <to uri="file://outputdir"/>
>        </route>
> <route>
>                 <from uri="activemq2:queue:ClusterTest"/>
>                 <to uri="file://outputdir"/>
>        </route>
>
>     </camelContext>
>
> <bean id="activemq1"
>      class="org.apache.activemq.camel.component.ActiveMQComponent">
>      <property name="brokerURL" value="tcp://10.200.14.164:61616"/>
>   </bean>
> <bean id="activemq2"
>      class="org.apache.activemq.camel.component.ActiveMQComponent">
>      <property name="brokerURL" value="tcp://10.200.208.223:61616"/>
>   </bean>
>
> </blueprint>
>
>
> :) :(
>
> Regards
> Guru
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909797.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

Hi Claus, It worked . But I am missing indefinite number of files in the
output directory.

<?xml version="1.0" encoding="UTF-8"?>
<blueprint
     xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="
       http://www.osgi.org/xmlns/blueprint/v1.0.0
       http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
     <camelContext xmlns="http://camel.apache.org/schema/blueprint"
trace="true">
	     

	   
	    <route>
    <from uri="file://inputdir/"/>

    <loadBalance>
        <roundRobin/>

        <to uri="activemq1:queue:ClusterTest"/>
        <to uri="activemq2:queue:ClusterTest"/>
        
    </loadBalance>
  </route>

	 <route>
		 <from uri="activemq1:queue:ClusterTest"/>
		 <to uri="file://outputdir"/>
	</route>
<route>
		 <from uri="activemq2:queue:ClusterTest"/>
		 <to uri="file://outputdir"/>
	</route>
  
     </camelContext>

<bean id="activemq1" 
      class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="brokerURL" value="tcp://10.200.14.164:61616"/>
   </bean>
<bean id="activemq2" 
      class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="brokerURL" value="tcp://10.200.208.223:61616"/>
   </bean>

</blueprint> 


:) :(

Regards
Guru

--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909797.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Claus Ibsen <cl...@gmail.com>.

Hi

The <bean> should be outside <camelContext>.

So you have

<blueprint>

    <!-- bean stuff here -->
   <bean>
   <bean>
   <bean>

   <camelContext>
       <!-- camel stuff here -->
   </camelContext>

</blueprint>

On Mon, Oct 17, 2011 at 2:19 PM, Gnanaguru S
<gn...@wipro.com> wrote:
>
> Claus,
>
> Please find my code below. As you said, Is this the way to achieve that ?
> <route>
>    <from uri="file://inputdir/"/>
>
>    <loadBalance>
>        <roundRobin/>
>
> *<bean id="activemq1"
>      class="org.apache.activemq.camel.component.ActiveMQComponent">
>      <property name="brokerURL" value="tcp://10.200.208.223:61616"/>
>   </bean>
>
>        <to uri="activemq:queue:test1"/>*
>
> *<bean id="activemq2"
>      class="org.apache.activemq.camel.component.ActiveMQComponent">
>      <property name="brokerURL" value="tcp://10.200.208.224:61616"/>
>   </bean>
>
>        <to uri="activemq:queue:test2"/>
>
> <bean id="activemq3"
>      class="org.apache.activemq.camel.component.ActiveMQComponent">
>      <property name="brokerURL" value="tcp://10.200.208.225:61616"/>
>   </bean>
>
>        <to uri="activemq:queue:test3"/>*
>
>    </loadBalance>
>  </route>
>
>
> Am i right, But the bundle is failed :(
>
> Regards
> Guru
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909701.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: Specifying different destinations using camel

Posted by Gnanaguru S <gn...@wipro.com>.

Claus,

Please find my code below. As you said, Is this the way to achieve that ?
<route>
    <from uri="file://inputdir/"/>

    <loadBalance>
        <roundRobin/>

*<bean id="activemq1" 
      class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="brokerURL" value="tcp://10.200.208.223:61616"/>
   </bean>

        <to uri="activemq:queue:test1"/>*

*<bean id="activemq2" 
      class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="brokerURL" value="tcp://10.200.208.224:61616"/>
   </bean>

        <to uri="activemq:queue:test2"/>

<bean id="activemq3" 
      class="org.apache.activemq.camel.component.ActiveMQComponent">
      <property name="brokerURL" value="tcp://10.200.208.225:61616"/>
   </bean>

        <to uri="activemq:queue:test3"/>*

    </loadBalance>
  </route>


Am i right, But the bundle is failed :(

Regards
Guru


--
View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909701.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Specifying different destinations using camel

Posted by Claus Ibsen <cl...@gmail.com>.

Hi

You define 3 different <bean> with an unique id, one per different broker.

eg

<bean id="activemq-foo" class="...">
  <!-- here goes broker configuration -->
</bean>

<bean id="activemq-bar" class="...">
  <!-- here goes broker configuration -->
</bean>

<bean id="activemq-baz" class="...">
  <!-- here goes broker configuration -->
</bean>

And then refer to them using "activemq-foo:queue:someQueueName" and
"activemq-bar:queue:someQueueName", and so forth.

See details here
http://camel.apache.org/activemq



On Mon, Oct 17, 2011 at 2:08 PM, Gnanaguru S
<gn...@wipro.com> wrote:
>
> Hi
>
> I have this scenario.
>
> I have three ActiveMQ brokers at different, I am using camels loadbalancing
> capability to avail HA. Below is my code:
>
> <?xml version="1.0" encoding="UTF-8"?>
> <blueprint
>     xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
>     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>     xsi:schemaLocation="
>       http://www.osgi.org/xmlns/blueprint/v1.0.0
>       http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
>     <camelContext xmlns="http://camel.apache.org/schema/blueprint"
> trace="true">
>
>
>
>            <route>
>    <from uri="file://inputdir/"/>
>
>    <loadBalance>
>        <roundRobin/>
>       * <to uri="HOST1:activemq:queue:test"/>
>        <to uri="HOST2:activemq:queue:test"/>
>        <to uri="HOST3:activemq:queue:test"/>*
>    </loadBalance>
>  </route>
>
>
>     </camelContext>
> </blueprint>
>
> As the lines marked in bold, I want to route to different brokers in
> roundrobin fashion. But i dont know how to specify different broker address
> in camel.
>
> please help me out.
>
> Such that i can achieve high availability through camel and AMQ.
>
> Hope my question was clear.
>
>
> Regards
> Guru
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Specifying-different-destinations-using-camel-tp4909674p4909674.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/