Hi,
I am still getting the same error.It is creating an empty folder at the
destination with the given name but at service mix it is throwing error.the
error is
at java.lang.Thread.run(Thread.java:595)
ERROR - DeadLetterChannel - On delivery attempt: 2 caught:
org.apac
he.camel.InvalidPayloadException: No in body available of type:
java.io.InputStr
eam but has value: [EMAIL PROTECTED] of type:
javax.xml.
transform.sax.SAXSource on the exchange: Exchange[FileMessage:
C:\MavenCheckSend
er\reports.txt]
org.apache.camel.InvalidPayloadException: No in body available of type:
java.io.
InputStream but has value: [EMAIL PROTECTED] of
type: ja
vax.xml.transform.sax.SAXSource on the exchange: Exchange[FileMessage:
C:\MavenC
heckSender\reports.txt]
at
org.apache.camel.util.ExchangeHelper.getMandatoryInBody(ExchangeHelpe
r.java:117)
at
org.apache.camel.component.file.FileProducer.process(FileProducer.jav
a:71)
at
org.apache.camel.component.file.FileProducer.process(FileProducer.jav
a:60)
at
org.apache.camel.impl.converter.AsyncProcessorTypeConverter$Processor
ToAsynProcessorBridge.process(AsyncProcessorTypeConverter.java:44)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:7
3)
at
org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChanne
l.java:136)
James.Strachan wrote:
>
> try this...
>
> from(...).process(
> new Processor() {
> public void process(Exchange exchange) {
> Message in = exchange.getIn();
> StreamSource source = in.getBody(StreamSource.class);
> if (source != null) {
> in.setBody(source.getInputStream());
> }
> }
> }).
> to(...)
>
>
>
> 2008/6/23 skg <[EMAIL PROTECTED]>:
>>
>> Hi,
>> In your specified code u have used an object "in".But u have not
>> specified
>> to which class it belongs.kindly review the code and resolve the issue.
>>
>> James.Strachan wrote:
>>>
>>> Yes - StreamSource is from JAXP...
>>>
>>> Google found this btw :)
>>> http://java.sun.com/j2se/1.4.2/docs/api/javax/xml/transform/stream/StreamSource.html
>>>
>>>
>>> 2008/6/23 skg <[EMAIL PROTECTED]>:
>>>>
>>>> Hi,
>>>> I applied the changes u have made and i am getting some compilation
>>>> errors.Do i need to import some package or and additional thing. The
>>>> error
>>>> is
>>>> [INFO] [compiler:compile]
>>>> [INFO] Compiling 1 source file to
>>>> C:\Parent\tutorial-camel-su\target\classes
>>>> [INFO]
>>>> ------------------------------------------------------------------------
>>>> [ERROR] BUILD FAILURE
>>>> [INFO]
>>>> ------------------------------------------------------------------------
>>>> [INFO] Compilation failure
>>>>
>>>> C:\Parent\tutorial-camel-su\src\main\java\org\apache\servicemix\tutorial\camel\M
>>>> yRouteBuilder.java:[39,148] cannot find symbol
>>>> symbol: class StreamSource
>>>>
>>>> from("jbi:endpoint:urn:org:apache:servicemix:tutorial:camel:jms:consumer
>>>> ").process(new Processor(){public void process(Exchange exchange) {
>>>> StreamSource
>>>> source = exchange.getIn().getBody(StreamSource.class);if (source !=
>>>> null)
>>>> {in.s
>>>> etBody(source.getInputStream());}}}).to("file:C:/MavenCheckSender/reports.txt");
>>>>
>>>>
>>>> C:\Parent\tutorial-camel-su\src\main\java\org\apache\servicemix\tutorial\camel\M
>>>> yRouteBuilder.java:[39,195] cannot find symbol
>>>> symbol: class StreamSource
>>>>
>>>> from("jbi:endpoint:urn:org:apache:servicemix:tutorial:camel:jms:consumer
>>>> ").process(new Processor(){public void process(Exchange exchange) {
>>>> StreamSource
>>>> source = exchange.getIn().getBody(StreamSource.class);if (source !=
>>>> null)
>>>> {in.s
>>>> etBody(source.getInputStream());}}}).to("file:C:/MavenCheckSender/reports.txt");
>>>>
>>>>
>>>> C:\Parent\tutorial-camel-su\src\main\java\org\apache\servicemix\tutorial\camel\M
>>>> yRouteBuilder.java:[39,236] cannot find symbol
>>>> symbol: variable in
>>>>
>>>> from("jbi:endpoint:urn:org:apache:servicemix:tutorial:camel:jms:consumer
>>>> ").process(new Processor(){public void process(Exchange exchange) {
>>>> StreamSource
>>>> source = exchange.getIn().getBody(StreamSource.class);if (source !=
>>>> null)
>>>> {in.s
>>>> etBody(source.getInputStream());}}}).to("file:C:/MavenCheckSender/reports.txt");
>>>>
>>>> James.Strachan wrote:
>>>>>
>>>>> This looks like a minor bug in the out-of-the-box type converters in
>>>>> Camel...
>>>>>
>>>>> https://issues.apache.org/activemq/browse/CAMEL-624
>>>>>
>>>>> I've just applied a patch so this will be fixed in 1.4.0. In the
>>>>> meantime you can add a processor to fix this...
>>>>>
>>>>> from(...).process(
>>>>> new Processor() {
>>>>> public void process(Exchange exchange) {
>>>>> StreamSource source =
>>>>> exchange.getIn().getBody(StreamSource.class);
>>>>> if (source != null) {
>>>>> in.setBody(source.getInputStream());
>>>>> }
>>>>> }
>>>>> }).
>>>>> to(...)
>>>>>
>>>>> 2008/6/20 skg <[EMAIL PROTECTED]>:
>>>>>>
>>>>>> Hi,
>>>>>> I am getting some error i am working on the third example given on
>>>>>> tutorial
>>>>>> and i replace the code in the tutorial with
>>>>>> from("jbi:endpoint:urn:org:apache:servicemix:tutorial:camel:jms:consumer").to("file:C:/MavenCheckSender/reports.txt");
>>>>>> but i am not getting any output in it and in service mix it is
>>>>>> showing
>>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>>> ERROR - DeadLetterChannel - On delivery attempt: 1
>>>>>> caught:
>>>>>> org.apac
>>>>>> e.camel.InvalidPayloadException: No in body available of type:
>>>>>> java.io.InputStr
>>>>>> am but has value: StringSource[<?xml version="1.0"
>>>>>> encoding="UTF-8"?><message>H
>>>>>> llo saurabh!</message>] of type:
>>>>>> org.apache.servicemix.jbi.jaxp.StringSource
>>>>>> on
>>>>>> the exchange: Exchange[FileMessage: C:\MavenCheckSender\reports.txt]
>>>>>> rg.apache.camel.InvalidPayloadException: No in body available of
>>>>>> type:
>>>>>> java.io.
>>>>>> nputStream but has value: StringSource[<?xml version="1.0"
>>>>>> encoding="UTF-8"?><m
>>>>>> ssage>Hello saurabh!</message>] of type:
>>>>>> org.apache.servicemix.jbi.jaxp.StringS
>>>>>> urce on the exchange: Exchange[FileMessage:
>>>>>> C:\MavenCheckSender\reports.txt]
>>>>>> at
>>>>>> org.apache.camel.util.ExchangeHelper.getMandatoryInBody(ExchangeHelpe
>>>>>> .java:117)
>>>>>> at
>>>>>> org.apache.camel.component.file.FileProducer.process(FileProducer.jav
>>>>>> :71)
>>>>>> at
>>>>>> org.apache.camel.component.file.FileProducer.process(FileProducer.jav
>>>>>> :60)
>>>>>> at
>>>>>> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$Processor
>>>>>> oAsynProcessorBridge.process(AsyncProcessorTypeConverter.java:44)
>>>>>> at
>>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:7
>>>>>> )
>>>>>> at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChanne
>>>>>> .java:136)
>>>>>> at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChanne
>>>>>> .java:86)
>>>>>> at
>>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProc
>>>>>> ssor.java:40)
>>>>>> at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp
>>>>>> r.java:44)
>>>>>> at
>>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy
>>>>>> cProcessor.java:68)
>>>>>> at
>>>>>> org.apache.servicemix.camel.CamelJbiEndpoint.processInOnly(CamelJbiEn
>>>>>> point.java:64)
>>>>>> at
>>>>>> org.apache.servicemix.common.endpoints.ProviderEndpoint.process(Provi
>>>>>> erEndpoint.java:100)
>>>>>> at
>>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>>>>>> eCycle.java:538)
>>>>>> at
>>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>>>>>> aseLifeCycle.java:490)
>>>>>> at
>>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>>>>>> ycle.java:46)
>>>>>> at
>>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>>>>>> (DeliveryChannelImpl.java:610)
>>>>>> at
>>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>>>>>> .java:172)
>>>>>> at
>>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>>>>>> va:167)
>>>>>> at
>>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>>>>>> :134)
>>>>>> at
>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
>>>>>> tor.java:650)
>>>>>> at
>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
>>>>>> java:675)
>>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>>>
>>>>>>
>>>>>> James.Strachan wrote:
>>>>>>>
>>>>>>> 2008/6/20 skg <[EMAIL PROTECTED]>:
>>>>>>>>
>>>>>>>> Hi,
>>>>>>>>
>>>>>>>> I worked with the example which uses jms to receive and send
>>>>>>>> message
>>>>>>>> to
>>>>>>>> web
>>>>>>>> services. The consumer receives the message on servicemix console
>>>>>>>> but
>>>>>>>> what
>>>>>>>> if I want the message in some file or some simple java objects such
>>>>>>>> as
>>>>>>>> hashmap. Can we store our message in that also.
>>>>>>>
>>>>>>> Reply soon
>>>>>>>
>>>>>>> So send to a file use the file endpoint...
>>>>>>> http://activemq.apache.org/camel/file.html
>>>>>>>
>>>>>>> e.g.
>>>>>>>
>>>>>>> from("activemq:SomeQueue").to("file://someDir");
>>>>>>>
>>>>>>> To work with beans and hashmaps, just send the message to a bean...
>>>>>>> http://activemq.apache.org/camel/bean-integration.html
>>>>>>>
>>>>>>> --
>>>>>>> James
>>>>>>> -------
>>>>>>> http://macstrac.blogspot.com/
>>>>>>>
>>>>>>> Open Source Integration
>>>>>>> http://open.iona.com
>>>>>>>
>>>>>>>
>>>>>>
>>>>>> --
>>>>>> View this message in context:
>>>>>> http://www.nabble.com/working-with-jms-tp18026353s22882p18026676.html
>>>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>>>
>>>>>>
>>>>>
>>>>>
>>>>>
>>>>> --
>>>>> James
>>>>> -------
>>>>> http://macstrac.blogspot.com/
>>>>>
>>>>> Open Source Integration
>>>>> http://open.iona.com
>>>>>
>>>>>
>>>>
>>>> --
>>>> View this message in context:
>>>> http://www.nabble.com/working-with-jms-tp18026353s22882p18063097.html
>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>>
>>> Open Source Integration
>>> http://open.iona.com
>>>
>>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/working-with-jms-tp18026353s22882p18065443.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>>
>
>
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://open.iona.com
>
>
--
View this message in context:
http://www.nabble.com/working-with-jms-tp18026353s22882p18065893.html
Sent from the Camel - Users mailing list archive at Nabble.com.
