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.
