I recently stumbled across the external route definition facility introduced in Camel 2.6: https://camel.apache.org/loading-routes-from-xml-files.html. This solved my problem perfectly well, as I simply load the route definitions and add them to the DefaultContext provided by akka. This at least allows me to externalize the routes without the need for modifying the source of a RouteBuilder instance.
On Saturday, December 14, 2013 9:45:01 PM UTC+13, Matteo Cusmai wrote: > > Hi all, > I have an issue similar to your. > > I would like to define my camel route using a spring xml, but I have found > out that akka camel extension uses DefaultCamelContext. > > I am trying your solution, but without success, where i am wronging? > > I have an xml file like this: > > <beans xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation=" > http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans.xsd > http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd";> > > <camelContext xmlns="http://camel.apache.org/schema/spring";> > > <route> > <from > uri="rabbitmq://localhost/SIM_DATA?exchangeType=topic&queue=rewardAquire1&username=guest&password=guest&routingKey=S1111BBB&autoDelete=false&threadPoolSize=1" > > /> > <to uri="direct:consumer1" /> > </route> > > </camelContext> > > </beans> > > A consumer like this > > public class CamelConsumer extends UntypedConsumerActor { > > private String _uri; > > private LoggingAdapter log = Logging.getLogger(getContext().system(), > this); > > @Override > public void preStart() { > log.debug( "preStart" ); > super.preStart(); > } > > public CamelConsumer() { > _uri = "direct:consumer1"; > } > > @Override > public String getEndpointUri() { > return _uri; > } > > @Override > public void onReceive(Object o) throws Exception { > if(o instanceof CamelMessage){ > CamelMessage camelMessage = (CamelMessage) o; > String message = camelMessage.getBodyAs(String.class, > getCamelContext() ); > transformer.tell(message, getSelf()); > } > else unhandled( o ); > } > > > } > > > finally a main like this: > > public class Main { >> >> public static void main(String[] args) throws Exception{ >> >> ClassPathXmlApplicationContext appctx = new >> ClassPathXmlApplicationContext("META-INF/camel-context.xml"); >> >> ActorSystem _system = ActorSystem.create("camel"); >> Camel camel = CamelExtension.get(_system); >> camel.context().setRegistry( new ApplicationContextRegistry( >> appctx) ); >> >> ActorRef ref = _system.actorOf( Props.create( >> SensorSupervisorActor.class ), "sensor" ); >> >> Thread.sleep( 600000 ); >> >> _system.shutdown(); >> >> } >> >> >> } >> >> > The consumer actor is create inside the supervisor, I omit it for sake of > simplicity. > > The error is the following: > >> org.apache.camel.component.direct.DirectConsumerNotAvailableException: No >> consumers available on endpoint: Endpoint[direct://consumer1]. >> Exchange[Message: <?xml version="1.0" encoding="utf-16"?> >> > > Can you suggest me the right solution? > Thanks in advance, > Matteo. > > > On Tuesday, 15 October 2013 09:55:31 UTC+2, Raymond Roestenburg wrote: >> >> >> >> On Tue, Oct 15, 2013 at 5:50 AM, nw31304 <[email protected]> wrote: >> >>> Thanks. Yep, that solved that part of the equation rather neatly. I had >>> my Actor extend ApplicationContextAware and this handler did the trick: >>> >>> def setApplicationContext(applicationContext: ApplicationContext) { >>> this.applicationContext = applicationContext >>> camel.context.setRegistry(new >>> ApplicationContextRegistry(applicationContext)) >>> camel.context.addRoutes(routeBuilder) >>> } >>> >>> >> Cool. >> >> >>> Now I'll have to concoct some way of getting route definitions out of >>> Spring XML and into Akka's Camel context. I shudder to think of having to >>> recompile a RouteBuilder every time I wanted to make a simple route change. >>> >> I shudder at the thought of Spring XML, so to each his own! ;-) >> >>> >>> >> But in any event, thanks to your tip I'm farther down the road. >>> >>> >> That's the good news. The bad news is that I now feel morally obligated >>> to buy your book. >>> >>> LOL :-) >> >> >>> --Dave >>> >>> >>> >>> On Tuesday, October 15, 2013 11:13:38 AM UTC+13, Raymond Roestenburg >>> wrote: >>> >>>> Have you tried setting the Registry on the DefaultCamelContext? >>>> >>>> http://camel.apache.org/how-does-camel-look-up-beans-and-endpoints.html >>>> >>>> there is a setRegistry on DefaultCamelContext. >>>> >>>> You might get this to work with creating an org.apache.camel.spring.spi. >>>> ApplicationContextRegistry >>>> and setting this on the DefaultCamelContext with setRegistry. >>>> >>>> That should make it possible to find your beans. >>>> >>>> >>>> >>>> On Mon, Oct 14, 2013 at 10:24 AM, nw31304 <[email protected]>wrote: >>>> >>>>> I am using akka-camel 2.2.1 and need to configure routes to and away >>>>> from Consumer and Producer actors, respectively. I am currently defining >>>>> routes and adding them to the internal Camel context within the >>>>> CamelExtension programmatically like so: >>>>> >>>>> camel.context.addRoutes(new RouteBuilder { >>>>> def configure() = { >>>>> >>>>> from("file:/tmp?include=whatever.*.log&noop=true&sendEmptyMessageWhenIdle=true") >>>>> .split(body(classOf[String]).tokenize("\n")) >>>>> .streaming() >>>>> .to("seda:input-route") >>>>> >>>>> from("seda:update-route") >>>>> .to("bean:db-update-bean?method=process") >>>>> }}) >>>>> >>>>> I have an Actor that extends Consumer which reads from >>>>> "seda:input-route" via its endPointUri, and another Actor that extends >>>>> Producer that writes to "seda:update-route". The "db-update-bean" in >>>>> defined in a Spring applicationContext.xml like so: >>>>> >>>>> >>>>> <bean id="db-update-bean" class="nz.co.whatever.DBUpdate"> >>>>> <constructor-arg ref="jdbcTemplate"/> >>>>> <constructor-arg value="some_other_constructor_arg"/></bean> >>>>> >>>>> >>>>> The Spring context is loaded and started in a supervisor Actor started >>>>> by akka.Main. However (and understandably), Camel is unaware of this >>>>> Spring >>>>> context, and thus went to great lengths to inform me that it had no clue >>>>> what the "db-update-bean" was: >>>>> >>>>> 2013-10-11 08:55:09,614 [SedaConsumer ] WARN Error processing >>>>> exchange. Exchange[Message: >>>>> 1378642997698,27684,true,57.000000,0.750000,97]. >>>>> Caused by: >>>>> >>>>> [org.apache.camel.NoSuchBeanException - No bean could be found in the >>>>> registry for: db-update-bean] >>>>> >>>>> >>>>> >>>>> Of course, I could programmatically add the components to the >>>>> akka-provided CamelContext, or else do something like this: >>>>> >>>>> >>>>> from("seda:update-route") >>>>> .bean(new DBUpdate(jdbcTemplate, "gps_temp_status"), "process") >>>>> >>>>> >>>>> but I would rather use Spring to define beans. Clearly, the >>>>> CamelExtension needs to use the Spring-defined CamelContext rather than >>>>> creating one of its own. >>>>> >>>>> Furthermore, and more importantly, I would like to externalize the >>>>> definition of the Camel routes into the same applicationContext.xml >>>>> within >>>>> a <CamelContext/> tag. Accoring to articles such as >>>>> https://weblogs.java.net/blog/manningpubs/archive/2013/02/ >>>>> 13/akka-and-camel, it seems the way to do so is to instantiate a >>>>> "camel-service" bean and inject the Spring-defined CamelContext as so: >>>>> >>>>> <camel:camelContext id="camelContext"> </camel:camelContext> >>>>> <akka:camel-service id="camelService"> >>>>> <akka:camel-context ref="camelContext" /></akka:camel-service> >>>>> >>>>> >>>>> Here is where the wheels come off. According to Roland Kuhn's reply in >>>>> Why >>>>> spring integration doc for akka exists only for 1.3.1 but not for next >>>>> versions<http://stackoverflow.com/questions/16948292/why-spring-integration-doc-for-akka-exists-only-for-1-3-1-but-not-for-next-versi>, >>>>> >>>>> the akka-spring library is not included in Akka 2.2.1, and thus there is >>>>> no >>>>> Spring namespace handler for akka, and I'm unable to instantiate this >>>>> camel-service bean. Though not for lack of trying. Or cursing. >>>>> >>>>> And so (finally), the question: How does one define Camel routes in >>>>> Spring XML whose endpoints can be used by Consumer or Producer Actors >>>>> using >>>>> akka-camel 2.2.1 without akka-spring? Does one instantiate a Factory bean >>>>> that produces a CamelService with a CamelContext injected or some other >>>>> such witchcraft? Secondarily (but related) how can I use Spring to >>>>> instantiate beans to be referenced in camel routes if I am forced to >>>>> define >>>>> them via a RouteBuilder? >>>>> >>>>> -- >>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>> >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>> >>>>>>>>>> Search the archives: https://groups.google.com/ >>>>> group/akka-user >>>>> --- >>>>> You received this message because you are subscribed to the Google >>>>> Groups "Akka User List" group. >>>>> To unsubscribe from this group and stop receiving emails from it, send >>>>> an email to [email protected]. >>>>> To post to this group, send email to [email protected]. >>>>> >>>>> Visit this group at http://groups.google.com/group/akka-user. >>>>> For more options, visit https://groups.google.com/groups/opt_out. >>>>> >>>> >>>> >>>> >>>> -- >>>> Raymond Roestenburg >>>> >>>> code: http://github.com/RayRoestenburg >>>> blog: http://roestenburg.agilesquad.com >>>> twtr: @RayRoestenburg >>>> book: http://manning.com/roestenburg >>>> >>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>> >>>>>>>>>> Search the archives: >>> https://groups.google.com/group/akka-user >>> --- >>> You received this message because you are subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to [email protected]. >>> To post to this group, send email to [email protected]. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/groups/opt_out. >>> >> >> >> >> -- >> Raymond Roestenburg >> >> code: http://github.com/RayRoestenburg >> blog: http://roestenburg.agilesquad.com >> twtr: @RayRoestenburg >> book: http://manning.com/roestenburg >> > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out.
