Re: Multiple JMS producer with IBMMQ

Hi Shadab! Sorry, I overlooked that you are talking about the producer. What is the source you are reading from? And may the thread() DSL element is helpful for you: from("xxx") .threads(3, 10, "threadName") .to("xxx"); Best, Christian - Software Integration Specialist

Re: Dispatch queue 'mqtt client' was not executing error from camel-mqtt producer

Hi, I filed a JIRA for this issue: https://issues.apache.org/jira/browse/CAMEL-7662 Thanks, Tomo -- IGARASHI Tomohisamailto:tm.igara...@gmail.com On Thu, Jul 17, 2014 at 4:03 PM, Tomohisa Igarashi wrote: > Hi Charles, > > I don't think it's a warning, please see this surefire report: > ht

MQTT producer failure

Hi, I'm still struggling with camel-mqtt producer to get it working. This is a previous thread: http://camel.465427.n5.nabble.com/Dispatch-queue-mqtt-client-was-not-executing-error-from-camel-mqtt-producer-tp5753937.html I made an example which runs a standalone camel route to verify camel-mqtt w

"simple programatic" camel and OSGi

Hi all, I have a fairly good understanding of OSGi, not so much of Camel internals. I'm trying to start a simple camel route involving rabbitmq in an OSGi container (simple file -> camel). (and incidentally I'm using the scala DSL, and camel version 2.13.2, inside a simple felix container) My pr

InterceptStrategy added to ToDefinition is not executed

Hello all, I have a question regarding InterceptStrategies. I'd like to add an InterceptStrategy that only intercepts a specific processing step (kind of an Around advice). After reading and trying a few things I have a solution that works by adding the InterceptStrategy during the addRoutesToCame

Re: "simple programatic" camel and OSGi

If you're not using Blueprint, then this is how you need to do it: 1. Create the Component instance somewhere (like a BundleActivator). 2. Register it as a service with at least the attribute "name" = "rabbitmq". 3. Now it's available from the default OSGi Camel registry! This is actually a point

Re: "simple programatic" camel and OSGi

Use OsgiDefaultCamelContext from camel-core-osgi and use the OsgiCamelContextHelper to hook it into the osgi world, as it does setup a bunch of stuff. On Tue, Aug 5, 2014 at 2:50 PM, Matt Sicker wrote: > If you're not using Blueprint, then this is how you need to do it: > > 1. Create the Com

Re: InterceptStrategy added to ToDefinition is not executed

Hi See this page http://camel.apache.org/advanced-configuration-of-camelcontext-using-spring.html And then only wrap the processor "when you want to do it" On Tue, Aug 5, 2014 at 2:47 PM, spa wrote: > Hello all, > > I have a question regarding InterceptStrategies. I'd like to add an > Intercept

Re: "simple programatic" camel and OSGi

Hi Matt, Thanks a lot for your reply. It's still not very clear though: 1. Create the Component instance somewhere (like a BundleActivator). > 2. Register it as a service with at least the attribute "name" = > "rabbitmq". > my service registry already contains the following service [org.apache.

Re: "simple programatic" camel and OSGi

Thanks Claus! I just figured it out after reading Matt's response :) On a side note, I really think things should be explained simply in these terms in the tutorials. The tutorial @ http://camel.apache.org/tutorial-osgi-camel-part1.html is quite scary just looking at the amount of dependencies an

Re: "simple programatic" camel and OSGi

Hi As the box on that page says that tutorial is outdated. Anyway fancy OSGi is surely welcome to write a new tutorial. We love contributions http://camel.apache.org/contributing.html And there is some OSGi / Karaf books also where some may touch a bit how to do this as well as you are doing. N

Re: Adding HTTP Headers to All Jetty Routes

Thanks Claus - I think this has gotten me on the right track, but I'm not quite there yet and am not sure why. Here are some snippets of code to help describe the problem. We are using the Groovy DSL and executing using "Main." Here is the new binding definition: class CORSHttpBinding exten

Can we use processStrategy inside the in the URI to poll the files over sftp?

Hi I am running with camel 2.9.2 .Below is the from uri using to poll the files from SFTP to local directory ,it gets connected than disconnecting and throwing an issue " INFO org.apache.camel.component.file.remote.SftpOperations - JSCH -> Caught an exception, leaving main loop due to socket cl

Re: "simple programatic" camel and OSGi

got you :) before i start contributing a new tutorial though, i'll try to learn how to use camel myself. i'll be coming back with more questions very soon! thanks -- View this message in context: http://camel.465427.n5.nabble.com/simple-programatic-camel-and-OSGi-tp5754790p5754810.html Sent

errorHandler and onException

Hi, I'm setting up a simple route that reads files and dumps them into a rabbitmq exchange. By default, the rabbitmq endpoint is configured as an "immediate exchange" which means that if no active consumer is present, an error is thrown. I don't have a consumer yet, so i simply expect everything t

Polling a directory for inner directories

Hi all, I am currently looking at the File2 processor, and it seems to me that my fairly simple use case isn't covered by this. I am a complete Camel newbie, so I am hoping someone can prove me wrong or suggest an alternative! I want to be able to watch a directory for changes, but I only want to

Re: Polling a directory for inner directories

Hi, Some time ago I did something like tjis using apache commons io and file observer. You may implement a recursive observer throwing events on sub directoy modify. Take a look here: http://commons.apache.org/proper/commons-io/apidocs/org/apache/commons/io/monitor/FileAlterationObserver.html Cheer

Re: Return aggregation of Splitter results, not splitter input

I figured it out. Simply changing split().body() to split(body(), new TestAggregationStrategry()) Allowed me to customize the result of the split/aggregation. I now have the aggregated results of TestTwo being sent to the response queue. -- View this message in context: http://camel.465427

Camel with Jackson will not run in JDK8, FYI

Just so everyone knows, you can't use Camel with Jackson on JDK8 until they fix JDK8 in u20: https://bugs.openjdk.java.net/browse/JDK-8035399 -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-Jackson-will-not-run-in-JDK8-FYI-tp5754815.html Sent from the Camel - Use

Return aggregation of Splitter results, not splitter input

Route definition: from("activemq:test_request_queue"). log("#1 ${in.body}"). bean(TestOne.class). // hard coded to return a String[3] log("#2 ${in.body[0]} ${in.body[1]} ${in.body[2]}"). split().body(). log("#3 ${in.body} ${property.CamelSplitIndex} ${property.CamelSplitSize} ${property.CamelSplit

Re: Polling a directory for inner directories

Hi There is a recursive option you can set to true. And there is also min/max depth options too. See the file docs at http://camel.apache.org/file2 On Tue, Aug 5, 2014 at 7:09 PM, jkir wrote: > Hi all, > > I am currently looking at the File2 processor, and it seems to me that my > fairly simple

Re: Camel with Jackson will not run in JDK8, FYI

An update to this: this only occurs when running with JDWP (i.e. in debug mode), which is why the JDK team dropped the severity of the bug. The workaround is to either not debug w/JDWP, or, when debugging to set the JVM arg -Djava.compiler=NONE. Your code will run a bit slower, but it's a do-abl

Re: Camel with Jackson will not run in JDK8, FYI

Camel 2.14 is the first release to support and be tested with Java 8. camel-core does NOT depend or use Jackson. It only has limited dependencies on slf4j and jaxb. On Tue, Aug 5, 2014 at 9:57 PM, heregear wrote: > An update to this: this only occurs when running with JDWP (i.e. in debug > mo

Dot notation for spring DSL properties fails for spring DSL route value

Configuration: JDK8, Camel 2.13, Spring, Spring property placeholder, text properties file Background: in order to create a dynamic URI for a route with a spring property, it’s required that you create an endpoint declaration, then refer to it: End point declaration:

Re: Dot notation for spring DSL properties fails for spring DSL route value

Hi Are you sure its Camel and not spring ? Camel uses {{ }} syntax, and Spring ${ }. So it sounds like you are using a spring property placeholder http://camel.apache.org/using-propertyplaceholder.html On Tue, Aug 5, 2014 at 11:54 PM, heregear wrote: > Configuration: JDK8, Camel 2.13, Spring,

Re: InterceptStrategy added to ToDefinition is not executed

Hi Claus, I have read this page already and basically it's what I am doing at the moment. The reason I use a handcrafted version of a context-wide interceptor is that the project is using Java EE 7 without any Spring involved, so I cannot use most of the Camel features that depend on Spring's func