Hi,
I’m trying to configure beanIO for one of my routes as follows Route
builderDataFormatformat=newBeanIODataFormat("mapping.xml","csvFile");from("direct:welcome").unmarshal(format).to("akka://mmb/user/sample").wireTap("file://log");
Not using Mixmax yet?
But I get the following
error.atakka.camel.ProducerSupport$$anonfun$produce$1.applyOrElse(Producer.scala:73)atscala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)atscala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)atscala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)atakka.camel.javaapi.UntypedProducerActor.onReceive(UntypedProducerActor.scala:51)atakka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)atakka.actor.Actor$class.aroundReceive(Actor.scala:467)atakka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)atakka.actor.ActorCell.receiveMessage(ActorCell.scala:516)atakka.actor.ActorCell.invoke(ActorCell.scala:487)atakka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)atakka.dispatch.Mailbox.run(Mailbox.scala:220)atakka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)atscala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)atscala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)atscala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)atscala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)Causedby:
java.lang.IllegalArgumentException:
Nostreammappingconfiguredforname'csvFile'atorg.beanio.internal.DefaultStreamFactory.getStream(DefaultStreamFactory.java:129)atorg.beanio.internal.DefaultStreamFactory.createReader(DefaultStreamFactory.java:70)atorg.beanio.StreamFactory.createReader(StreamFactory.java:98)atorg.apache.camel.dataformat.beanio.BeanIODataFormat.readModels(BeanIODataFormat.java:148)atorg.apache.camel.dataformat.beanio.BeanIODataFormat.unmarshal(BeanIODataFormat.java:116)atorg.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:67)atorg.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)atorg.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)atorg.apache.camel.processor.Pipeline.process(Pipeline.java:118)atorg.apache.camel.processor.Pipeline.process(Pipeline.java:80)atorg.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)atorg.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51)atorg.apache.camel.processor.SendProcessor.process(SendProcessor.java:129)atakka.camel.ProducerSupport$ProducerChild.produce(Producer.scala:137)atakka.camel.ProducerSupport$ProducerChild$$anonfun$receive$1.applyOrElse(Producer.scala:111)atakka.actor.Actor$class.aroundReceive(Actor.scala:467)atakka.camel.ProducerSupport$ProducerChild.aroundReceive(Producer.scala:108)
... 9more
Not using Mixmax yet?
Do I need to configure an explicit stream. I use akka-camel
