Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread Yuffie
Hi,Willem Thanks for your help! I think I need to read the document carefully first. Again, thank you! -- View this message in context: http://camel.465427.n5.nabble.com/Why-so-many-port-used-when-I-use-camel-netty4-http-tp5765433p5765810.html Sent from the Camel - Users mailing list archive a

Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread Yuffie
Hi,Yogesh. Thanks for help! Since I don't have a Linux environment, I don't if it work on Linux. But it work in win7. And I will try what you said. Again thank you. -- View this message in context: http://camel.465427.n5.nabble.com/Why-so-many-port-used-when-I-use-camel-netty4-http-tp5765433p57

Re: Apache Camel @Netflix

2015-04-14 Thread Claus Ibsen
Hi Great to hear that its not only the Chaos Monkeys that roam inside Netflix. But that its the Camel's that are trusted the most critical app, the one that takes our money and gives it to Netflix ;) On Tue, Apr 14, 2015 at 11:26 PM, Christian Müller wrote: > Also Netflix is using Apache Camel

Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread Willem Jiang
Hi Yuffie I just went through the link which explains that why windows need to establish loopback connection for selector. It looks like you use camel camel-netty4-http to build a proxy to route the message for you.  Now back to camel-netty4-http, there is a producer pool which cache the Channe

Re: Substring from nth character to nth from the end

2015-04-14 Thread yogu13
Hello, Since you are going to reduce the length by 1, you can try using the unary operator which would be like ${body.length}-- also the other thing you can try is enclosing the operation as an expression ${${body.length} - 1} Note: i havent tried this, but perhaps you can check and let us know

Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread yogu13
Hello, Apart from the above can you provide us following info !! 1. How many ports are opened (delta) for the route which is getting created?? You can do this by taking a note of all the ports opened when you application is down and then take a note of the ports open once your application is up a

Re: About property place holder

2015-04-14 Thread yogu13
Hello, Please let us know version of spring and camel ? long back i too had a similar issue and came across this post -> http://camel.465427.n5.nabble.com/constant-in-setProperty-is-not-compatible-with-property-placeholder-Spring-context-td494411.html

Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread yogu13
Thanks! Is this working properly in any of the environments ? Also you try configuring the bootstrap options like keepAlive, Timeout's and disconnect for netty endpoint ? check "Reusing same server bootstrap configuration with multiple routes" section in http://camel.apache.org/netty4-http.html

Re: Why so many port used when I use camel-netty4-http

2015-04-14 Thread Yuffie
Hi,Willem. this is my RouteBuilder: --- public class MobileRouteBuilder extends RouteBuilder implements PropertyConstants { private String port; public void setPort(String port) { this.port = port; } priv

Re: Virtual Topic isn't working

2015-04-14 Thread hayden74
Thanks Paul, I will give it another go when I get home. Do I also need to change the Camel side to publish to a queue instead of a topic? eg:change Camel side from from("jms:queue:foo").to("activemq:topic:VirtualTopic.bar"); to from("jms:queue:foo").to("activemq:queue:VirtualTopic.bar"); Tha

Re: Virtual Topic isn't working

2015-04-14 Thread Paul Gale
There's still a problem with your code. This: String number = consumerTemplate.receiveBody("activemq:topic:Consumer.A.VirtualTopic.bar", String.class); must be changed to this: String number = consumerTemplate.receiveBody("activemq:queue:Consumer.A.VirtualTopic.bar", String.class); Despite bein

Re: Virtual Topic isn't working

2015-04-14 Thread hayden74
Thanks Paul, That was a typo, the code now looks like: Camel side: from("jms:queue:foo").to("activemq:topic:VirtualTopic.bar"); onsumerTemplate consumerTemplate = context.getBean("consumerTemplate", ConsumerTemplate.class); String number = consumerTemplate.receiveBody("activemq:topic

Apache Camel @Netflix

2015-04-14 Thread Christian Müller
Also Netflix is using Apache Camel in its payment processing engine [1]. [1] https://www.youtube.com/watch?v=k_ckJ7QgLW0#t=515 Best, Christian - Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PM

Substring from nth character to nth from the end

2015-04-14 Thread erd
Hello, I have a route in Spring that has been converted to a string. I only want the 8th character to 3rd from the end, so I tried to transform based on indices. Here is what I've tried. ${body.substring(8,${body.length}-1)} the message is 10989 characters long, so it tries to cas

About property place holder

2015-04-14 Thread Alan Camillo
When I use new ConstantExpression("{{email.msg.status}}") the property place holder *works*. but when I try constant("{{email.msg.status}}") property place holder *doesn't work*. and the line simple("{{email.msg.status}}") property place holder *works* too. Did I do something wrong? Thanks! Alan

Bi-directional comms on TCP connection

2015-04-14 Thread Carl Nygard
I have a question about the Mina/Netty TCP connector in Camel. Can Mina/Netty handle bi-directional comms through Camel, or do we need to handle this type of interface externally? We have embedded devices (button/light combo) that will consume TCP messages to light a device and initiate messages t

Re: Wiretap not firing events?

2015-04-14 Thread rwijngaa
Thanks Claus! For now, as a workaround (i'm stuck at camel 2.12 for the moment), i do something like the thing below in my wiretap : .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { // some trick to get the correc

Re: Wiretap not firing events?

2015-04-14 Thread rwijngaa
Thanks Claus! For now, as a workaround (i'm stuck at camel 2.12 for the moment), i do something like the thing below in my wiretap : .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { // some trick to get the c

Re: Virtual Topic isn't working

2015-04-14 Thread Paul Gale
I believe your client should look like this: String msg = consumerTemplate.receiveBody("activemq:queue:Consumer.blah.VirtualTopic.BAR", String.class); ...where 'blah' is replaced with an identifier (that does not contain period characters) of your choosing. Thanks, Paul On Tue, Apr 14, 2015 at

Re: camel-ftp 2.15.1 return ftp error code 421

2015-04-14 Thread alexey-s
An exemplary work plan Ftp consumer. As we can see, at the beginning of a connection to the server. FTPClient establishes a new connection for a list of files in each directory. At the end of the first connection is switched off. Why hold the first connection? Another question. Some directorie

Re: Wiretap not firing events?

2015-04-14 Thread Claus Ibsen
Hi I was fast and logged a ticket and have a fix in the works https://issues.apache.org/jira/browse/CAMEL-8634 On Tue, Apr 14, 2015 at 3:06 PM, Claus Ibsen wrote: > Hi > > Ah yeah that is an oversight, we should add the event notifier to do > that as well. You are welcome to log a JIRA > > On Tu

Virtual Topic isn't working

2015-04-14 Thread hayden74
Hi guys, I am having trouble consuming messages from a Virtual Topic. Basically I want messages from FOO queue to be published to VirtualTopic.BAR. Here is what I have so far: Camel side from("jms:queue:FOO").to("activemq:topic:VirtualTopic.BAR"); Consumer side: ConsumerTemplate consumerTemplate

Re: Wiretap not firing events?

2015-04-14 Thread Claus Ibsen
Hi Ah yeah that is an oversight, we should add the event notifier to do that as well. You are welcome to log a JIRA On Tue, Apr 14, 2015 at 2:57 PM, rwijngaa wrote: > Hi, > > We use an extension of EventNotifierSupport to log all camel messages > (from/to) to Elasticsearch. > This works fine for

Wiretap not firing events?

2015-04-14 Thread rwijngaa
Hi, We use an extension of EventNotifierSupport to log all camel messages (from/to) to Elasticsearch. This works fine for all routes except for a wiretap route (that sends a newExchange). This wiretap route does not seem to fire AbstractExchangeEvents. Is this correct? Shouldn't it send these eve

Re: How to use Apache camel -file component to do a pattern match & rename the file

2015-04-14 Thread yogu13
Please use this and let us know... Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/How-to-use-Apache-camel-file-component-to-do-a-pattern-match-rename-the-file-tp5765695p5765751.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to use Apache camel -file component to do a pattern match & rename the file

2015-04-14 Thread niteshjain
Hi, i don't know how it is modifying the URL after i deploy, so i removed "&" before include java.util.regex.PatternSyntaxException: Illegal repetition near index 17 Sample.*xml?move=${date:now:MMdd}/${file:name}.processed ^ at java.util.regex.Pattern.error(Pattern.

Handling splitting and error handling

2015-04-14 Thread blommish
from("direct:inbound") .multicast().parallelProcessing().to("direct:a", "direct:b"); //message a from("direct:a").processRef("processor_a").to("validator:a.xsd") .multicast().parallelProcessing().to("jms:q1", "jms:q2"); //message b from("direct:b").processRef("processor_b").to("validator:b.xs

Re: How to use Apache camel -file component to do a pattern match & rename the file

2015-04-14 Thread Claus Ibsen
Hi It has to be a valid uri, file:///opt/jboss-fuse-6.1.0.redhat-379/myfolder/?=&include=Sample should be file:///opt/jboss-fuse-6.1.0.redhat-379/myfolder/?include=Sample On Tue, Apr 14, 2015 at 9:55 AM, niteshjain wrote: > getting an ResolveEndpointFailedException > > Caused by: org.apache.c

Re: How to use Apache camel -file component to do a pattern match & rename the file

2015-04-14 Thread niteshjain
getting an ResolveEndpointFailedException Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: file:///opt/jboss-fuse-6.1.0.redhat-379/myfolder/?=&include=Sample.*xml%3Fmove%3D%24%7Bfile%3Aname%7D.processed due to: There are 1 parameters that couldn't be set on t