camel - Activemq performance suggestions

Hi, Can anyone suggest any performance improvement techniques for camel-activemq We have tried connection pooling mentioned in this page http://camel.apache.org/activemq.html Here is my xml and route configuration from("netty:tcp://10.44.71.187:7000?te

Re: How to start a process with Camel?

Hi Can you be more specific with what you mean with separate process? There is an exec to run an executable http://camel.apache.org/exec On Fri, Jun 21, 2013 at 1:19 AM, Sean Beck wrote: > So I have figured out how to gather messages based on my criteria. A > process needs to be started as so

Re: Runtime modification of redelivery policy

The allows you to modify its configuration at runtime using JMX. This way you can change the maximum redeliveries On Thu, Jun 20, 2013 at 8:07 PM, swwyatt wrote: > Given a redelivery policy contained within an onException, is there a way to > modify the policy attributes at runtime? I want to be

Issue in Camel to process the xml file

Hi, I am trying to upload the around 100 mb file from one server to different. First I am trying to copy the file from one server to the server where my application is running. Below are the issue I am facing. 1. When file copy is in-progress status, camel application start picking up the file an

RE: camel sftp privateKeyFile - load from classpath

Hi, You are right, the current implementation doesn't work with identity and known hosts files from anywhere but the file system. JSch has actually three ways of setting these entities, one with a filename (which camel uses now), one with an InputStream and one with implementations of the Ident

How to start a process with Camel?

So I have figured out how to gather messages based on my criteria. A process needs to be started as soon as two messages have been received. Currently I have: from("jms:newFileQueue").aggregate(new HeaderExpression("CamelFileName")).completionSize(2).to("triggerservice to process and merge files")

Re: Camel Integration Advice Needed

Christian, thank you for your response. I've stumbled upon the camel XML tag , http://camel.apache.org/loading-routes-from-xml-files.html, that I think will fit the bill quite nicely. It should allow a user to define a route template that, prior to loading into a camel context can have template fie

Re: C library for using Camel

I'm going through some code examples and the JavaDoc and I can't seem to find where to() is documented. I was told to use something like from("jms:newFileQueue").aggregate(header("CamelFileName")).completionSize(2).to("triggerservice to process and merge files") to do what I need. I can't find whe

Re: C library for using Camel

I don't think you are looking for a C camel library. Rather a library to talk to activemq (either 'native' or http REST) which in turn talks to camel. On 20 June 2013 21:05, Sean Beck wrote: > Hi all, > > I am new to Camel and was directed to use it for some functionality I want > to build int

Re: Producer Template Failure on Glassfish AIX

I was able to get a hold of IBM tech and added these flags to the domain JVM options (all in one line): When I tried to deplay the war, it did create dump (core) files within the domain/config directory. I've uploaded to IBM. I'll post any responses I get once they review. -- View this mes

Re: Runtime modification of redelivery policy

You may looking for "retryWhile" [1]? [1] http://camel.apache.org/exception-clause.html Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://www.apache.org/foundation/ Apache Member: https://www.apache

Re: List contains in Simple?

I guess that is why it is called "simple" :) Can you inject in properties (body, exchange properties, etc.) in to other language expressions then? Is there an example out there similar to what I am trying to do? Thanks! -- View this message in context: http://camel.465427.n5.nabble.com/List-c

Re: C library for using Camel

No. Best, Christian Sent from a mobile device Am 20.06.2013 22:05 schrieb "Sean Beck" : > Hi all, > > I am new to Camel and was directed to use it for some functionality I want > to build into my code. > > So I am sending files over to a server and there are two files with the > same name but of

Re: List contains in Simple?

For this, you have to use a more powerful script language. Best, Christian Sent from a mobile device Am 20.06.2013 22:25 schrieb "javamonkey79" : > I tried adding toString on and it did not work either... > > ${body.get("KEY").toString()} in ${bean:test} > > Is this possible to do? > > > > -- >

Re: List contains in Simple?

I tried adding toString on and it did not work either... ${body.get("KEY").toString()} in ${bean:test} Is this possible to do? -- View this message in context: http://camel.465427.n5.nabble.com/List-contains-in-Simple-tp5734458p5734470.html Sent from the Camel - Users mailing list archive at

RE: camel sftp privateKeyFile - load from classpath

@Stephan - that is a bit over my head, perhaps I don't understand the sftp component and jsch well enough yet. What I do know is that jsch is taking the String param passed in via Camel (the fileName param) and turning that in to a File, which I don't think will work with classpath resources? There

List contains in Simple?

Is it possible to do a list.contains in the simple language? I had something like this: ${body.get("KEY")} in ${bean:listRef} But it did not work. (My body object was a Map, listRef was an ArrayList). Thinking back, the only thing that I might have done wrong is that the Map was whereas the A

C library for using Camel

Hi all, I am new to Camel and was directed to use it for some functionality I want to build into my code. So I am sending files over to a server and there are two files with the same name but of a different "type" that are merged together on the server side. As soon as a file is received I send a

Re: Security: Input validation in camel

Yes, there is no explicit input validation. Yes, you can add a generic OwaspInterceptor by using "interceptFrom()". It's global per Camel context. Best, Christian - Software Integration Specialist Apache Camel committer: https://camel.apache.org/team V.P. Apache Camel: https://ww

Re: seda endpoint and UoW

Sorry, I read in other discussion thread that this is the normal behavior since Exchange is the same across routes. However my doubt now if I can achive the behaivor I was expeting if I do this trick: Route 1: . . . There is another required beha

Runtime modification of redelivery policy

Given a redelivery policy contained within an onException, is there a way to modify the policy attributes at runtime? I want to be able to set the maximumRedeliveries specifically. java.lang.Exception

seda endpoint and UoW

Hi, I have an strange behavior with seda endpoint and the Unit Of Work demarcation: Route 1: Endpoint A -> (processor chain) -> Endpoint B (seda) In this route is configured a onCompletion callback Route 2: Endpoint B -> (processor chain) -> Endpoint C In this scenario onCompletion executes

Security: Input validation in camel

Hi folks, is there any input validation in camel regarding secure coding guidelines as the OWASP suggests (check for nullbytes, hazardous characters, and so on)? My research in the mailinglist and the wiki didn't turn up anything, but that doesn't mean there is no such thing. If there is really

Re: Activemq consumer is closing

we were seeing similar issues and tracked it back to and ActiveMQConnectionPool idleTimeout issue: https://issues.apache.org/jira/browse/AMQ-4366 the solution for us was to explicitly set the idleTimeout to 0 to disable this ActiveMQMessageConsumer.checkClosed() logic... indrayani wrote > Hi , >

Re: Camel JMS retry mechanism

What broker are you using? On Wed, Jun 19, 2013 at 5:27 AM, Richa wrote: > The exception listener does not work because the exception is not thrown. I > checked the underlying classes in the jar. In the > DefaultMessageListenerContainer.java, there is method > refreshConnectionUntilSuccessful()

Re: Activemq consumer is closing

You should post your connection pool and JmsComponent settings. Are you using transactions? Are you caching your consumers? On Thu, Jun 20, 2013 at 2:54 AM, indrayani wrote: > below is the full stack trace > > > 2013-06-20 12:24:25,656 [yManager[inbox]] WARN TemporaryQueueReplyManager > - Exce

Re: Http component didn't give response in case failover policy

Hi Maybe this FAQ helps? http://camel.apache.org/why-is-my-message-body-empty.html On Thu, Jun 20, 2013 at 2:30 PM, mayank.gupta wrote: > Hi All , > > I am using camel Http component to post xml over http on Http Server . I am > using Load balancer having failover policy , but i didn't get the r

Re: Jackson question... why does this fail?

I don't think it's crap. It's a byte array of your JSON string. Simple add a convertBodyTo(String) to get a String. Best, Christian Sent from a mobile device Am 20.06.2013 02:45 schrieb "Mike Oxford" : > > > > ... > >// mina compone

Http component didn't give response in case failover policy

Hi All , I am using camel Http component to post xml over http on Http Server . I am using Load balancer having failover policy , but i didn't get the response from exchange while I use round robin policy over LB , it responses me properly in exchange body. Now ,there is the requirement, i have

Re: camel 2.11 release with activemq-camel 5-8?

Thanks a lot Christian! It worked. BR, Lefteris -- View this message in context: http://camel.465427.n5.nabble.com/camel-2-11-release-with-activemq-camel-5-8-tp5733244p5734440.html Sent from the Camel - Users mailing list archive at Nabble.com.

Web server in ServiceMix with camel-jetty or camel-servlet

Hello, We are trying to send blob messages (large files) through an ActiveMQ broker integrated in ServiceMix. It seems that this operation requires a ftp or a http server for upload and download and we are wondering if this can be achieved with a servicemix camel component implementation. I am loo

Re: Dynamic uri not working

Hi See this FAQ http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html On Thu, Jun 20, 2013 at 1:33 PM, sprabu wrote: > Hi, > When i try to construct dynamic URI. Its not working here, i'm trying > configure gmail USER NAME and PASSWORD details dynamically from header. Buts > its not workin

Dynamic uri not working

Hi, When i try to construct dynamic URI. Its not working here, i'm trying configure gmail USER NAME and PASSWORD details dynamically from header. Buts its not working for me. Please help me to come out of it. Also i referred the following link to do this, even then its not working. http://camel.46

Re: How to get failed recipient list name in camel

Thanks for your quick response Claus Ibsen-2.i am using the same way whatever you suggested to me like exchange.getProperty(exchange.FAILURE_ENDPOINT, String.class) for checking this i am manually throwing exception at the time preparing recipient list its showing failed recipient as last name i

RE: camel sftp privateKeyFile - load from classpath

Hi, Maybe it would be more flexible to optionally inject Identiy and KnownHostsRepository instances in the jsch.addIdentity() and jsch.setHostKeyRepository(). The implementation of these interfaces could get the actual key material from arbitrary formats and sources (so you are not required to

Re: Sticky load balancer and failover support

Hi You can extend the existing fail over load balancer and implement your custom logic for chose processor, to be sticky based. Though you would not have that nice in the DSL. On Tue, Jun 18, 2013 at 2:48 PM, DavideC wrote: > Sorry, the source was not readable. HYG > > >

Re: Camel routes and threads

Hi You can read about thread stuff here http://camel.apache.org/threading-model.html You can also share thread pools among the routes. Or reduce the sizes of the thread pool profiles etc. Also some Camel components have consumers that support parallel processing such as seda / jms / jetty / cxf

Re: camel sftp privateKeyFile - load from classpath

Hi Yeah fell free to look into this. Maybe we can load the key file using an InputStream etc. You can use the ClassResolver API from CamelContext to load resources and classes from classpath. That should work for both OSGi and non OSGi runtimes. On Wed, Jun 19, 2013 at 6:55 PM, javamonkey79 wro

Re: Content based routing with InOut pattern and exclusive reply queue

Hi The reply queue is NOT exclusive. You use it 2 times for route1 and route2 in the content based router. On Thu, Jun 20, 2013 at 12:26 PM, Tomas Potocky wrote: > Hi folks, > I've found some strange behaviour using content based routing in camel. Can > someone tell me what's wrong with followi

Content based routing with InOut pattern and exclusive reply queue

Hi folks, I've found some strange behaviour using content based routing in camel. Can someone tell me what's wrong with following setup and why I get PersistentQueueReplyManager:86 - Reply received for unknown correlationID for route2 when using Exclusive queue for replies? If I use temporary queue

Re: camel 2.11 release with activemq-camel 5-8?

The activemq-camel component is provided by ActiveMQ. The version 5.8.0 use Camel 2.10.3. This is the reason why it pulls in the 2.10.3 version. Camel 2.11.0 use ActiveMQ 5.8.0 (and activemq-camel) for it's own unit tests. So it will work, if you exclude the Camel 2.10.3 dependencies in Maven (I as

Re: PollingConsumerSupport

Hello Christian, Thanks for the reply. I went through the docs and the examples. I was kind of confused if the code snippet below can be called from a producer endpoint: Endpoint endpoint = context.getEndpoint("activemq:my.queue"); PollingConsumer consumer = endpoint.createPollingConsumer(); Exch

Re: Autosys poller

Hello Christian, Thanks for the reply. The problem is i was confused if we should implement our custom endpoint ("autosys" ) as ScheduledPollConsumer or a PollingConsumer ? I think it should be a Polling consumer which blocks. Howevere since its in the .to , that would make it a producer, thus can

Re: Activemq consumer is closing

below is the full stack trace 2013-06-20 12:24:25,656 [yManager[inbox]] WARN TemporaryQueueReplyManager - Exception inside the DMLC for Temporary ReplyTo Queue for destination inbox, refreshing ReplyTo destination javax.jms.IllegalStateException: The Consumer is closed at org.apache.