Selective Consumer in a clustered environment

Hi, I have a doubt in a HA setup. I have a camel application which has a JMS endpoint, say 'Entry' queue. I have deployed this application in a 4 node cluster. But I want only one node to be active at a time. For example if one Camel node is receiving any message, the other node should NOT a

Re: Activemq consumer is closing

Hi We have created activemq consumer with property autostartup = false. So the queue wasn't created and it while it was trying to write to the queue (which doesn't exist) we got that exception. Once we changed that autostartup = true , it was fine. - Regards kiran Reddy -- View this mes

Re: Camel JMS retry mechanism

Richa, You can use maximumRedeliveries option to achieve this. Eg: errorHandler(defaultErrorHandler().maximumRedeliveries(3)); Hope you routes are wrapped by onException clauses. Futher you can refer here for redelivery and route policies: http://camel.apache.org/redeliverypolicy.html Thank

Camel JMS retry mechanism

Hi, I have a camel route having JMS as input location. I want to handle the scenario when JMS is down. I would like to restrict the number of retries to 2 in case JMS is down. But when I looked through the messageListenerContainer class I realized that the method which is called to connect to the J

Camel routes and threads

Hello, As I learnt, each route in camel runs in its own thread unless its a direct endpoint. We have a configuration, where we have 14 different routes inside the camel context: We are seeking clarification on following points: 1. the defaultThreadPolicy has poolSize="10" maxPoolSize="20". Does t

Re: Hibernate with restlet

Thanks Muller. I started with sql component. On 19 June 2013 02:03, Christian Müller wrote: > I'm afraid, this use case isn't supported yet. > If you use the hibernate-component in a "to()", it will do an > insert/update. This is the same for the JPA component. > You should consider to use the

Re: Camel Context InterceptStrategy

I guess you already studied http://camel.apache.org/intercept.html Best, Christian Sent from a mobile device Am 18.06.2013 12:45 schrieb "Zhemzhitsky Sergey" < sergey_zhemzhit...@sberbank-cib.ru>: > Hello guys, > > I’d like to apply custom intercept strategy to a given camel context > running in

Re: Activemq consumer is closing

There is not enough input that we can start digging into it... http://camel.apache.org/support.html Best, Christian Sent from a mobile device Am 18.06.2013 14:01 schrieb "indrayani" : > Hello, > can you explain what is the actual solution you applied in order to avoid > this exception. > I am f

Re: Servet Componnet HttpSession

It looks like Camel caches the client connection as long as URL is exactly the same. This causes multiple requests by different browser clients to use same session id. Is this expected behavior? It does not seem correct to me for two different clients to have the same session id on server simply

Re: Consume opened excel file with ftp

You can use the bridgeErrorHandler to discard this exception. Camel will try to consume this file again in the next poll. But this is more a work around... You should consider to write the file into a different directory and move it into the directory Camel is polling afterwards. Best, Christian

Re: camel deployment options...

Hi Ben! I hope you are doing good. We missed you at CamelOne in Boston... I would recommend Tomcat, if: - you don't have to support updating individual bundles at run time without to have a downtime of the entire application (of course it doesn't work if you provide a JAX-WS, JAX-RS, ... interfac

Re: MailComponent/MailConsumer misses Mails

Using log4j.logger.org.apache.camel.component.mail=DEBUG should be fine. I would like to see the log entries at the time Camel mark/flag more messages as seen as messages were processed. And could you please check whether do you see the same strange Java Mail log messages (2 RECENT but no message

Re: Camel Mustache & Handlebars components

If you want to contribute the component(s) to Apache Camel (we love contributions), you should: 1) open a JIRA at https://issues.apache.org/jira/browse/CAMEL 2) Attach the component as patch file or create a pull request (please mention the JIRA ticket number) 3) Attach the the documentation for th

Re: Hibernate with restlet

I'm afraid, this use case isn't supported yet. If you use the hibernate-component in a "to()", it will do an insert/update. This is the same for the JPA component. You should consider to use the sql or jdbc component. Best, Christian Müller - Software Integration Specialist Apac

Servet Componnet HttpSession

I've setup a proxy using Tomcat Servlet component but when end point service receives Http request the HttpSessionId is the same for all clients when the proxy is involved. Is there a special setting that needs to be enabled for Servlet component? I noticed only Jetty component has "sessionSuppor

Problem with Camel FTP component because of bug in commons-net

Hi, I just stumbled upon a bug in Apache Commons Net 3.2 / FTPClient. The bug is known and fixed in Commons Net 3.3: https://issues.apache.org/jira/browse/NET-502 The problem was with the FTP producer, when after putting a file to the server, I got a 5xx error as Camel tries to change back to

Re: MailComponent/MailConsumer misses Mails

Hello, I've updated our customers qa system to camel 2.11.0 and mail 1.5 now. We've added some test routes to send mails to the mail box we are reading from and had a look at it if mails are missing. After ~1 hour we saw that sent mails vs. received mails was not equal anymore and analyzed the lo

Re: Camel Mustache & Handlebars components

Hi Claus, You can do what you want with this source code. I can do a pull request or patch if you wish. The Mustache component works perfectly in our case: it's simple and fast. The Handlebars component/engine is slow at times. Gérald 2013/6/16 Claus Ibsen-2 [via Camel] < ml-node+s465427n57342

Re: Need original message at the end of the route

It works :) exchange.getUnitOfWork().getOriginalInMessage(); Thank you /Sarfaraj -- View this message in context: http://camel.465427.n5.nabble.com/Need-original-message-at-the-end-of-the-route-tp5734290p5734307.html Sent from the Camel - Users mailing list archive at Nabble.com.

Hibernate with restlet

Hi All, I completed the basic hibernate example given in http://camel.apache.org/hibernate-example.html Now I trying hibernate with restlet in apache camel. I want to return a row(s) from database, with a REST GET request. That means a simple select query over database. How to achive this scenari

Re: Need original message at the end of the route

It is a CXF web service -- View this message in context: http://camel.465427.n5.nabble.com/Need-original-message-at-the-end-of-the-route-tp5734290p5734305.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Need original message at the end of the route

This only seems to be done for JmsMessages though. What is the source of your route? -- View this message in context: http://camel.465427.n5.nabble.com/Need-original-message-at-the-end-of-the-route-tp5734290p5734303.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Performance Degradation due to Reverse DNS Lookups

We already do something similar: SSLContext ctx = SSLContext.getInstance("SSL"); ctx.init(null, new TrustManager[] { new TrustAllTrustManager() }, null); SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);

Re: Need original message at the end of the route

Yes Diether, I thought of Original Message before. But didn't get a way to access that. Could someone know how to get it ? /Sarfaraj -- View this message in context: http://camel.465427.n5.nabble.com/Need-original-message-at-the-end-of-the-route-tp5734290p5734301.html Sent from the Camel - Us

Re: Need original message at the end of the route

I had a quick look at the source code and apparently it is already stored on the exchange, and you can get it from the UnitOfWork. from("direct:/start") .process(new Processor() { @Override public void process(Exchange exchange) throws Exception {

Re: Exception when using FTP as endpoint

You may have to provide proper credentials (user & password)? Best, Christian Sent from a mobile device Am 18.06.2013 08:02 schrieb "Richa" : > I have two camel routes. The first camel route takes input from JMS and > sends > to FTP location. Also, the first rotue sends that file to a seda locat

Re: Need original message at the end of the route

did u try streamcache? http://camel.apache.org/stream-caching.html -- View this message in context: http://camel.465427.n5.nabble.com/Need-original-message-at-the-end-of-the-route-tp5734290p5734299.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Sticky load balancer and failover support

Sorry, the source was not readable. HYG //*[local-name() =

Re: Need original message at the end of the route

Saving it on the headers, files or database is probably the easiest way. However, I know that when using exeception handlers you have the option to get the original message: http://camel.apache.org/exception-clause.html#ExceptionClause-UsinguseOriginalMessage So I asume the original message is alr

Consume opened excel file with ftp

Hello. I'm sorry i'm really a newbie with Camel. I'm using Camel to get file in a FTP server. Here how i'm routing it: The file is a Excel file. When this file is not opened, the download and the process work perfectly. Bug if the FTP server owner save the file in the ftp directory (so it is s

Sticky load balancer and failover support

Hi all,I'm trying to implement a sticky balancer using camel framework. Following camel-example-cxf-proxy example I managed to do the following: //*[local-name() = 'incidentId']/text()

Re: Activemq consumer is closing

Hello, can you explain what is the actual solution you applied in order to avoid this exception. I am facing the same issue and I really need a help. -- View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734294.html Sent from the Camel - Us

Re: Need original message at the end of the route

Hi, might consider to store it right in the beginning either to a temp file system or into a database which you could consume on a second route, or with a 6th processor. regards, Achim 2013/6/18 sarfaraj > I have camel route. In that, I need to have original message which I > received/consume

Need original message at the end of the route

I have camel route. In that, I need to have original message which I received/consumed in tag at the end of same route (Like below) without using/setting to header or property. As that message is too heavy. I don't want to let down the performance. Do we have any other me

Re: two way ssl with a camel cxf proxy use case on Tomcat

these are two different things (the inbound side configuration you already have and the outbound side configuration you asked for) and depending on what you need at each side, you can configure them independently. 2013/6/17 Nico Mommaerts > Ok thanks! Had already read that but wasn't sure if t

Camel Context InterceptStrategy

Hello guys, I’d like to apply custom intercept strategy to a given camel context running in an OSGi environment at runtime. I’ve implemented osgi service-reference listener (blueprint) that is notified when the camel context appears. When the listener is invoked the intercept strategy is added

camel-hdfs 2.11.0 & karaf & blueprint

Hi I'm trying to use camel-hdfs with karaf & blueprint but I get the error below But I'm not sure if the problem is karaf/osgi/blueprint or my tcp port setting. According to https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.20/src/hdfs/hdfs-default.xml which is the parameter

Camel Integration Advice Needed

I have a custom code module which I would like to integrate with an AMQP message bus. In the past I've created (in another language) a messaging broker which managed connections and subscriptions to the AMQP bus. Now creating the code in Java and having discovered Camel I'm trying to write the co

Re: ActiveMQ Component: Stop route when no more messages are being received

Thanks Claus, But the exchange.getContext().getInflightRepository.size(routeName) gives me some unpredictable stats. May be I haven't understood it well. The workaround I used is: I wrote a custom stats collector which I wire in the routes of interest. I then just query the variable containing th

mass async processing - cxf async bot webservice and client

Hallo I need high load - 160 req/s - with large timeout - 20 s - proxy for failover and load balancing, it has to serve async 6400 pending requests. I have following case: I have to expose webservice, which logic is to return result of call of another webservice A-ws, if call to A-ws timeout, I h