Re: camel:netty udpConnectionlessSending option and "Too many open files"

How did you use the camel:netty component? Camel always try to reuse the cached channel object if it is possible, can you share some detail of your camel route. -- Willem Jiang Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo:

Re: Getting JMSConsumer to look for messages every N seconds

Or use the timer component to send a message each 10 seconds to a processor. This processor could use a consumer template to poll the queue in a loop and send the message to another camel route with a producer template (using the direct component ). The consumer template also has a timeout

Camel features using karaf feature xml

Hi, How do I get camel features automatically installed by a feature xml. In my scenario, I am creating my own Karaf feature xml to install all dependent bundles before my bundles can be started. From what I observe, few camel features such as camel-core, camel-http4, camel-jackson are

Polling messages from topics ActiveMQ

Dear fellow camelriders, At the moment I want to poll messages from a specific topic in ActiveMQ using camel in eclipse. from("activemq:topic:test").log("transfered to file") .to("file:src/data"); Getting the following error: Exception in thread "main" java.lang.NoClassDefFoundError:

Re: How can I manually redelivery the message to source endpoint while an exception throws?

Hi Greg, I appreciate your quickly response. I know Camel has OnException to catch the exception, as well as the auto re-delivery mechanism. But in some case, user hope they can manually to resubmit the message. For example, if the exception throws, we need serialize Message/Exchange object as

Processing N files at a time - Threads

I have seen the various posts for processing files concurrently, and I have seen the various types of errors that result from it. As others have done I managed to get around the issue by somehow limiting the poll from the file consumer, or using an idempotentConsumer before the threads, in my case

Re: Workaround with REST DSL to avoid HTTP method not allowed - 405

Hi Charles, You have to enable the CORS on the route DSL configuration, not only on the routes level. For example here is the REST+Netty combination for Camel 2.15.1 that works properly with the AngularJS REST client: RestPropertyDefinition corsAllowedHeaders = new RestPropertyDefinition();

Executing PERL script in Camel route

Am trying to execute a PERL script from my route XML. I use the following syntax, But i don't see the script being executed. This is the log i see, 23:28:44,243 INFO [org.apache.camel.component.exec.ExecProducer] (Camel (camelAgent) thread #5 - JmsConsumer[ISEEOutboundQueue]) Executing

Configure a camel route to start and stop at certain time of day

Hi, I have a requirement where my camel route should only pick up new messages between 8am and 10pm due to database backups and other nightly processes. I have looked at the SimpleScheduledRoutePolicy class but i'm not sure how to use it to start and stop routes at predefined times every day.

High Volume ETL using camel

Hello Geeks We are a huge retail organization with over 1500 stores as well as online shopping websites. Volumes of messages at the middleware run probably over a billion daily. Currently we have a commercial product by another vendor taking up the responsibility. We plan to move out systems

Re: Dynamic DataSource

Chistian, yes the datasource is configured in the camel context, when the dataSource is hard coded it works : from("direct:create") .to("sql:insert into customer(firstname, lastname) values(:#firstName, #lastName)?dataSource=#myDynamicSource")); Arnaud -- View this message in context:

Re: kyro data format in camel

here is the class implementataion also. public final class KyroDataFormat implements DataFormat { @Override public void marshal(Exchange exchange, Object graph, OutputStream stream) throws Exception { stream.write(new

BeanIO - No Stream mapping configured

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

How can I manually redelivery the message to source endpoint while an exception throws?

Hi All, As we known, Camel has auto redelivery machanism, but sometimes, we need re-delivery the message to source endpoint while delivery faild. Nomally, we need to process below steps. 1. While an exception throws, we will save the Exchange/Message to the database. 2. Provide a page to modify

Re: kyro data format in camel

ohh Sorry for that, below is the part where it is used.

salesforce dto generator: Unrecognized field "is_readonly" in LoginToken

perhaps a new salesforce field "is_readonly" is needed in LoginToken to fix the DTO generator? [INFO] --- camel-salesforce-maven-plugin:2.15.3:generate (default-cli) @ salesforceIntegration --- [DEBUG] Dependency collection stats: {ConflictMarker.analyzeTime=0, ConflictMarker.markTime=0,

Re: Workaround with REST DSL to avoid HTTP method not allowed - 405

Hi Henryk, Some additional infos : I'm using jetty component & Camel 2.15.1.redhat-620133. CORS has been enabled at the level of the REST Configuration ( https://github.com/FuseByExample/rest-dsl-in-action/blob/master/routing/src/main/java/org/jboss/fuse/route/RestToServicesRoute.java) as you

RE: redeliveryPolicy onException based on HTTP statusCode

Thank you for this anwser Vanshul.Chawla, that was exactly what I was looking for. Amazing how simple it can be. -- View this message in context: http://camel.465427.n5.nabble.com/redeliveryPolicy-onException-based-on-HTTP-statusCode-tp5771448p5771485.html Sent from the Camel - Users mailing