Adding Jackson MixIns in RestDSL

2015-09-14 Thread abazylewicz
Hello, I tried do add Jackson MixIns to ObjectMapper, to support serialization of third-party objects in my rest routes (which is done by eg. objectMapper.addMixInAnnotations(, ); I tried setting custom DataFormat for my Rest configuration but from this (https://issues.apache.org/jira/browse/CAME

High Volume ETL using camel

2015-09-14 Thread contactreji
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 soon

Executing PERL script in Camel route

2015-09-14 Thread anish.somadevan
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 ExecCom

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

2015-09-14 Thread briane80
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. Can

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

2015-09-14 Thread Charles Moulliard
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 can

salesforce dto generator: Unrecognized field "is_readonly" in LoginToken

2015-09-14 Thread rpcat
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, Conflict

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

2015-09-14 Thread Henryk Konsek
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();

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

2015-09-14 Thread zhichao....@hpe.com
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 S

Processing N files at a time - Threads

2015-09-14 Thread pkx
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

Polling messages from topics ActiveMQ

2015-09-14 Thread S-camel
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: o

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

2015-09-14 Thread Charles Moulliard
Hi, I try to see if there is a workaround to avoid this issue (HTTP method not allowed - 405) or If I have to dig into the code to provide a fix 1) HTTP Method 405 - returned This REST DSL definition generates a HTTP 405 Method not allowed when this request is issued (http -v OPTIONS http://loca

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

2015-09-14 Thread Greg Autric
Hi Zhi-Chao Fei, You can catch exception via OnException mechanism http://camel.apache.org/exception-clause.html If you can reply everything you want to the client (HTTP) feel free to send your sample if needed Greg AUTRIC JBoss Middleware Consultant email : gautric

Re: Getting JMSConsumer to look for messages every N seconds

2015-09-14 Thread Christian Müller
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 paramete

Camel features using karaf feature xml

2015-09-14 Thread Ravi Nallappan
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 installe

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

2015-09-14 Thread Willem Jiang
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: 姜宁wil

BeanIO - No Stream mapping configured

2015-09-14 Thread Sashika
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.ca

Re: kyro data format in camel

2015-09-14 Thread fxthomas
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 KryoSerializationUtil(

Re: kyro data format in camel

2015-09-14 Thread fxthomas
ohh Sorry for that, below is the part where it is used.

Re: Dynamic DataSource

2015-09-14 Thread arnaud
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: http

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

2015-09-14 Thread zhichao....@hpe.com
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 t