Parallel file processing with Camel

2013-10-23 Thread piyushbhatt
Hi, We are using Camel and have developed an FTP client using it. We generate hundreds of files which we need to push in a very short time window to the FTP server. All these files reside in the same directory. Camel is not able to keep pace with number of files so we do manual parallel pushing us

Re: Parallel file processing with Camel

2013-10-23 Thread contactreji
I would recommend avoiding filezilla. Could you try with an alternative FTP server. There is a FTP server which is shipped with Linux os. Give a try with that. Meanwhile try FTP options like stream data .. Refer camel documentation for stream options Reji "piyushbhatt [via Camel]" wrote:

Can't sent many sms with smpp. Producer binding problems.

2013-10-23 Thread mamouros
I am using camel smpp to send sms to an smsc but when testing it live, i get "Negative response 0005 found" which means "ESME_RALYBND 5 ESME already in bound state (example: sending a second bind command during an existing SMPP session)". In the beginning I thought it happened because of one

define properties in context.xml

2013-10-23 Thread Olaf
Hello, is it possible to define properties in spring xml directly without using a .properties file? And then use them in java like that: from(imap://imap.server.com?username={{user}}&password={{pass}}) or from({{imapUri}}) I'd like to have only one xml config file Thanks for help! -- View

Re: Request for help with Twitter component | Sending direct messages to multiple users

2013-10-23 Thread Claus Ibsen
I dont assume the camel-twitter can send DM to 2+ recipients in one go. Though you can look at the twitter4j api whether that would be possible. In Camel you can use a recipient list or multicast to send the same message to N+ endpoints. http://camel.apache.org/eip Or use a dynamic router to "loo

Re: Parallel file processing with Camel

2013-10-23 Thread Claus Ibsen
Hi You can use threads, see bottom of this page http://camel.apache.org/async.html On Wed, Oct 23, 2013 at 9:16 AM, piyushbhatt wrote: > Hi, > > We are using Camel and have developed an FTP client using it. We generate > hundreds of files which we need to push in a very short time window to th

Re: define properties in context.xml

2013-10-23 Thread Claus Ibsen
You can define them in a java.util.Properties bean - Maybe Spring has a XML namespace syntax for that to make it nicer looking. Then you can refer to this bean using ref: as shown on http://camel.apache.org/using-propertyplaceholder.html On Wed, Oct 23, 2013 at 10:16 AM, Olaf wrote: > Hello, > >

Re: define properties in context.xml

2013-10-23 Thread Olaf
Thanks! I'll try that -- View this message in context: http://camel.465427.n5.nabble.com/define-properties-in-context-xml-tp5742054p5742060.html Sent from the Camel - Users mailing list archive at Nabble.com.

camel-cxf and activemq example

2013-10-23 Thread harry
Hi, Can anybody help me finding any working example/tutorial on camel-cxf,activemq example in jboss fuse6. Any quick help is highly appriciated. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/camel-cxf-and-activemq-example-tp5742069.html Sent from the Camel - Users m

Encapsulate each field by double quotes

2013-10-23 Thread Aviraj
Hello, I am trying to encapsulate the data in CSV file by double quotes with CSVStrategy Configuration. But the data in the CSV is not encapsulated by double quotes. The code snippet is as below, public void configure() throws Exception { CsvDataFormat format = new CsvDataFormat();

Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread berdoni
Hi, I have the the following route: from("quartz://MyTrigger/TriggerRouteStart?cron=0+0/5+*+*+*+?") .routeId("TriggerRouteStart") .to("activemq:queue:TriggerRouteStart"); This route should trigger every 5mins and put a message to TriggerRouteStart queue however I get the following error. Shall I

Re: Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread Claus Ibsen
Yes you need to set the body to something, such as constant("") for an empty string or what you want. On Wed, Oct 23, 2013 at 2:25 PM, berdoni wrote: > Hi, > > I have the the following route: > from("quartz://MyTrigger/TriggerRouteStart?cron=0+0/5+*+*+*+?") > .routeId("TriggerRouteStart") > .to("

how to give the dynamic value to the tokenizeXML

2013-10-23 Thread dkum003
Hi, I want to give the dynamic value to the tokenizeXML. My code snippet is below: .split() .tokenizeXML(tokenType, 100) .streaming() Here my requirement to change the value of tokenType for every run. Thanks & Regards, Dhananjay Kumar Amadeus Lab SSE -- View this message in context: http:

Re: Encapsulate each field by double quotes

2013-10-23 Thread Claus Ibsen
I suggest to look in the commons CSV project about how to use double quotes. And if that is supported, and that you configure the CSVStrategy correct? Also you can try alternatives than CSV such as camel-beanio etc as its an up to date and maintained project, where as commons csv is a sort of dead

Re: Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread Claus Ibsen
Hi This sounds like a classpath issue. Make sure to use the same Camel version for all your Camel JARs. On Wed, Oct 23, 2013 at 4:00 PM, berdoni wrote: > I did it by adding the following processor but the problem persists. > > .process(new Processor() { > public void process(

Crashing on Startup

2013-10-23 Thread Gershaw, Geoffrey A. (KFFC 223)
Hello All, I am running Camel 2.11.0 and it appears it crashed this AM. This is all we have in the log. The dump must be moved somewhere to conserve disk. Any thoughts? Thanks 02:00:12,387 [main] INFO com.csfb.fid.credit.cds.MainSpring - Starting Camel. Use ctrl + c to terminate the JVM.

Re: Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread berdoni
The v2.12.1 Camel version is used for all camel components, however camel-jms 2.10.3 is used by activemq-camel component. This jar causes the classpath issue as Christian mentioned in his relevant post. I have updated my pom and it seems OK now with Camel v2.12.1. org.apa

Re: error while testing: duplicate id detected

2013-10-23 Thread Claus Ibsen
Hi You add the routes 2 times with both in the spring XML file using and @Override protected RouteBuilder createRouteBuilder() throws Exception { return new App.AppRoute(); } On Tue, Oct 22, 2013 at 9:56 PM, Olaf wrote: > Hello, > > I have a simple route, which works fine

Re: Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread berdoni
I did it by adding the following processor but the problem persists. .process(new Processor() { public void process(Exchange exchange) { Message in = exchange.getIn(); in.setBody("Dummy Body"); }

Re: how to give the dynamic value to the tokenizeXML

2013-10-23 Thread Claus Ibsen
You would need to use java code where you can dynamic set the token and return the tokenizer .split().method(MyBean.class, "myMethod") And then implement the method public static Expression myMethod(Exchange exchange) { ... TokenizeLanguage tok = new TokenizeLanguage(); tok.setXml

Re: how to give the dynamic value to the tokenizeXML

2013-10-23 Thread contactreji
Hi Kumar You can have logic to calculate it in components like processor and add it to the exchange header.. And later in splitter component, you can refer the value from header using {in.header.tokenNameFromHeader} Look out for more ideas from forums users too! Cheers Reji On Wed, Oct 23, 20

[BLOG] JMS-style selectors on Amazon SQS with Apache Camel

2013-10-23 Thread Christian Posta
For those interested, I've put together a blog that shows a new functionality with upcoming Apache Camel 2.13.0. The code with the blog shows using the new json-path component as well... Take a look and interested in any feedback: http://www.christianposta.com/blog/?p=340 -- *Christian Posta

Re: [BLOG] JMS-style selectors on Amazon SQS with Apache Camel

2013-10-23 Thread jb
Hi Christian, thanks for sharing this, it's very interesting. Did you update the article section of the website ? Thanks again Regards JB On 2013-10-23 17:45, Christian Posta wrote: For those interested, I've put together a blog that shows a new functionality with upcoming Apache Camel 2.13.0

endChoice() in Camel Scala DSL

2013-10-23 Thread abhinavm
Hello, I have a scenario, where some code needs to go into choice, some in otherwise, and some common clean-up code needs to be executed after that in both scenarios. Since I could not find endChoice() or end() in the Scala DSL, I tried the following piece of code, but could not achieve what I wan

Re: ActiveMq-InOut: save exchange body

2013-10-23 Thread Christian Müller
What kind of issue do you face? Best, Christian - Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PMC Member https://www.linkedin.com/pub/christian-mueller/11/551/642 On Tue, Oct 22, 2013 at 1

Re: camel-cxf and activemq example

2013-10-23 Thread Christian Müller
Did you checked [1]? [1] http://camel.apache.org/examples.html Best, Christian - Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PMC Member https://www.linkedin.com/pub/christian-mueller/11/551

Re: Body is null exception when producing JMS messages from a Quartz endpoint

2013-10-23 Thread Christian Müller
Good to know you got it working... Best, Christian - Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PMC Member https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Oct 23, 2013 a

Best way to consuming same queue from two brokers?

2013-10-23 Thread dunnlow
Using Camel 2.10.3 My question: What is the best way to consume msgs from multiple brokers/queues and feed those messages through a single route? Explanation: I currently consume from an activemq broker. I have several different routes that consume messages from different queues on that broker.

Re: Best way to consuming same queue from two brokers?

2013-10-23 Thread James Carman
The NoB should be routing your messages for you, shouldn't it? On Wed, Oct 23, 2013 at 1:52 PM, dunnlow wrote: > Using Camel 2.10.3 > > My question: What is the best way to consume msgs from multiple > brokers/queues and feed those messages through a single route? > > Explanation: > > I currentl

Spring ASM issue with Camel + CXF

2013-10-23 Thread Charles Moulliard
Hi, Using Spring 3.1.3.RELEASE + Camel 2.12.1 + CXF 2.7.7, I get this exception java.lang.IncompatibleClassChangeError: class org.springframework.core.LocalVariableTableParameterNameDiscoverer$ParameterNameDiscoveringVisitor has interface org.springframework.asm.ClassVisitor as super class when

Re: error while testing: duplicate id detected

2013-10-23 Thread Olaf
Oh, no... Thank you very much! -- View this message in context: http://camel.465427.n5.nabble.com/error-while-testing-duplicate-id-detected-tp5742041p5742102.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Spring ASM issue with Camel + CXF

2013-10-23 Thread Daniel Kulp
I’d suggest a “mvn dependency:tree” and see what’s there. It sounds like a mis-match of versions of spring jars. Possibly a 3.2.x version of spring-asm being picked up but a 3.1.x version of core or similar. Dan On Oct 23, 2013, at 1:59 PM, Charles Moulliard wrote: > Hi, > > Using Spri

Re: Best way to consuming same queue from two brokers?

2013-10-23 Thread dunnlow
Thanks James. Well, yes... sort of. If a producer sends to one broker, I can consume from either as expected...IF both brokers are ok. My concern (that I have from my relayed past experience) is that if I use the failover uri and there is a problem, that my consumer will miss some of the message

Re: Best way to consuming same queue from two brokers?

2013-10-23 Thread James Carman
Remember that a NoB is not a "cluster", per se. There is no replication between brokers. So, if one broker goes down while there are messages sitting on it, then those messages are lost until the broker comes back online. If you're looking for high availability, then you're barking up the wrong

Re: How to Use ProducerTemplate for testing secure CXF-WS?

2013-10-23 Thread sjfloat
Frank, Did you have any luck with this? I'm attempting to do something similar. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-Use-ProducerTemplate-for-testing-secure-CXF-WS-tp5730894p5742107.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: endChoice() in Camel Scala DSL

2013-10-23 Thread Willem jiang
Hi As Scala supports to passing a block, you don't need to use endChoice() or end() to close the choice() Here is an example for it choice { when(simple("${body} == 'foo'")) to "mock:foo" otherwise to "mock:other" } to("mock:end") -- Willem Jiang On Wednesday, October 23, 2013 at 11:46 PM,

how to know which email receipt is failure for what reason

2013-10-23 Thread ishwar
hi, i am sending the email using following code. public boolean sendEmail(JSONObject data) { boolean status=false; camel = new DefaultCamelContext(); template = camel.createProducerTemplate();

Camel is not transfering the files sometimes

2013-10-23 Thread Bharath
Hi, My Camel application has a simple route say from(file).to(sftp).Files transferred successfully when i deploy my application initially and after sometime the files are not moving from the Source location to the destination and the source location is getting accumulated by files..There is no

Re: ActiveMq-InOut: save exchange body

2013-10-23 Thread ak-dak
Hi, I have a simple example which works as expected: --- *Camel-Routes:* http://camel.apache.org/schema/spring";>

Re: Best way to consuming same queue from two brokers?

2013-10-23 Thread contactreji
Hi Dunnlow If you are using in memory queue, have you thought about using seda: instead of direct : ? seda would be able to store message since its asynchronous and can buffer up data in case other routes dont come up on time . But direct is highly synchronous. Might have data loss of consumers