Re: mongodb distinct query

Claus, I created a ticket in JIRA and submitted a patch. Let me know if there's anything more I can do to support this functionality. https://issues.apache.org/jira/browse/CAMEL-11259 Cheers, Mark On Tue, May 9, 2017 at 7:15 AM, Mark wrote: > Thanks Claus, I'm going

Re: ERROR [org.apache.camel.component.jms.DefaultJmsMessageListenerContainer]

I solved my problem (hang Queue listeners) by using the asyncRequestBody (see: http://camel.465427.n5.nabble.com/ProducerTemplate-timeout-td473382.html) JEE Container Servlet (HttpSessionTimeout) { Camel Routes { JMS Request/Reply

Re: OnApplicationEvent not called with CamelAutoConfiguration

Hi, I've created a pull request[1] to start the discussion if we could do better in this case. Can you help by reviewing or checking it out and trying it on your end to confirm that it helps? thanks :) [1] https://github.com/apache/camel/pull/1685 On Wed, May 10, 2017 at 9:48 PM, Zoran Regvart

Apache Shiro annotation support in Apache Camel

Hi, I configured Apache Shiro in order perform authorisation of rest service, it works fine as per provided examples but I want to use annotations like: import org.apache.shiro.authz.annotation.RequiresPermissions; @RequiresPermissions("my:create:message") public void sendmessage() { ... }

Re: OnApplicationEvent not called with CamelAutoConfiguration

Hi, if the promises stated at Graceful shutdown in the documentation[1] are broken then this is a bug, from the sideline to me this looks more like AMQ-3988[2]. So as Claus was saying, if you have Spring managed JMS connection pool that is being shutdown before Camel gets to perform the graceful

Camel 2.17.4 - High CPU Utilization

Hi, We are using the below ThreadPoolProfile configuration in our application When found for high CPU Utilization, we analyzed the application using Java Flight Recorder and found that we are spawning 4500+ threads but we have configured to support maxPoolSize of 2500 for the above three

onFailureOnly onCompleteOnly does not produce the right route

I have a road defined as well where onCompletion onException onFailure are functions The route builder produce only onException and onFailure If I change the order of call functions I've only one of onCompleteOnly or onFailureOnly is produced haw to add onCompleteOnly and onFailureOnly ?

Re: OnApplicationEvent not called with CamelAutoConfiguration

So its not a bug in the SpringCamelContext handled by CamelAutoConfiguration ? What you are saying is that its not related to the onApplicationEvent method and the shutdownEager ? I'm lost really thought it was that and calling it was fixing it though ... -- View this message in context:

Re: problem when using elasticsearch5 component with camel-2.19.0

Hi Rachid, you seem to be missing `org.elasticsearch.transport.Netty3Plugin` class, perhaps the ServiceMix users forum at: http://servicemix.396122.n5.nabble.com/ServiceMix-User-f396123.html can help you with that, zoran On Wed, May 10, 2017 at 7:02 PM, Rachid KRAIEM

problem when using elasticsearch5 component with camel-2.19.0

Hi everybody, I've install camel-elasticsearch5 component with the newer apache-2.19.0 into karaf-4.0.7 container my camel route is as follow: the problem is when trying to install my bundle, i have the following problem Can you help me ?? Regards, Rachid KRAIEM -- View this message

Re: Camel with embedded ActiveMQ / Web-Console

Hi Burner, have you configured the Spring Boot Maven plugin?[1] zoran [1] https://docs.spring.io/spring-boot/docs/current/reference/html/build-tool-plugins-maven-plugin.html -- Zoran Regvart

Re: Async bean method

Hi Morten, are you using the JMS component? Take a look at `concurrentConsumers` and `asyncConsumer` properties[1], zoran [1] https://camel.apache.org/jms.html#JMS-ConcurrentConsuming On Wed, May 10, 2017 at 4:20 PM, mortalisk wrote: > Guess I am mistaken about

Properties dynamic doesnt work

Hi, i'm using camel 2.17.6 in Servicemix 7. i try to use LOOP to dynamically use key properties , it doesnt work Did i missed domething ! then header CamelFilePath don't substitute ??? *Here the content of my properties file:* *Here my code:* *Here my log* -- View this message in

Re: Configuring Quartz in cfg file (Property placeholder)

You can use classpath: as prefix to refer to the classpath. And file: to refer to the file system. Then you can refer to the KARAF_HOME/etc folder and the file name there. On Wed, May 10, 2017 at 3:42 PM, Kevin-Void wrote: > Yes Claus.. Is there a way to use

Re: Camel with embedded ActiveMQ / Web-Console

I get it now to work, but only when I make "mvn camel:run". But I want "mvn package". Knows anyone, what I must do? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-embedded-ActiveMQ-Web-Console-tp5798586p5799238.html Sent from the Camel - Users mailing list

Re: Problem using setProperty() with groovy() on optional Field

Thanks for your reply. I tried this before, but the property "source" is then null in the next steps even if the source field was present in the XML. Really strange.. btw: Camel Version is 2.17.1 best regards -- View this message in context:

Re: Problem using setProperty() with groovy() on optional Field

Hi, it found a solution which works but it is not really nice to me.. any ideas to make it smarter? .. choice().when(body().convertToString().contains("\"source\"")).setProperty("source").groovy("request.body.source").end() ... Best regards -- View this message in context:

Re: Configuring Quartz in cfg file (Property placeholder)

Yes Claus.. Is there a way to use quartz.properties file externally like cfg file or properties file outside the jar :( Regards, Kevin -- View this message in context: http://camel.465427.n5.nabble.com/Configuring-Quartz-in-cfg-file-Property-placeholder-tp5799160p5799232.html Sent from the

ad vitam aeternam redelivery

Hi, I need to define an endpoint with the following characteristics: Transactional route from jms to any protocols (user-defined protolole during config) Retry every x seconds in case of failure No attempt limit Rollback if the route stops after a failure. I work with camel 2.16 Thank you for

Re: Problem using setProperty() with groovy() on optional Field

That's strange. I mean worst case scenario, create an inline processor and extract the xml and check the field and extract the field value and put in source property.This way you are sure what should happen. On Wed, May 10, 2017 at 4:29 PM, Mic [via Camel] < ml+s465427n5799236...@n5.nabble.com>

Re: Async bean method

Guess I am mistaken about whenComplete blocking the thread. I thought that was the difference of *Async and not in the CompletableFuture, so never mind that. However I still see this behaviour where only one message is processed at a time, even though all the code is running in a separate thread

Re: Async bean method

My route: In the executor bean (only message type was changed to : It definitely seems to only run the "process" method one by one. I added a sleep in "preProcess" (which is inside the "thenApplyAsync" so it should not block the camel thread, which would make it wait for that much longer until

Re: Problem using setProperty() with groovy() on optional Field

I don't know the groovy version but simple language has null safe operator. Can't you write it like this: .setProperty("source").simple("${request.body.source?") See here for examples: http://camel.apache.org/simple.html On Wed, May 10, 2017 at 3:32 PM, Mic [via Camel] <

ProducerTemplate thread waits indefinitely

I am using producerTemplate.asyncCallback(., ., .) method to publish messages to Tibco EMS. While running my application, if EMS server down then so-many threads as blocking and my server is creating lot of blocking threads then it moving to out of memory issue here is the connection code

Problem using setProperty() with groovy() on optional Field

Hi guys, i struggle with the following case. I have a "body" with some fields like "title", "source" etc.. Now i would like to set a Property with the value in field "source". The problem is, the field is optional, so it is not present always. It works if it is present with

Re: OnApplicationEvent not called with CamelAutoConfiguration

You need somehow to tell spring to shutdown those thread pools last, there is some way of defining bean ordering or depends-on in spring. Check the spring docs On Wed, May 10, 2017 at 1:40 PM, Hetmoteus wrote: > Hi, > > When I shutdown the application with at least 1

Re: OnApplicationEvent not called with CamelAutoConfiguration

Hi, When I shutdown the application with at least 1 inflight exchange I get the following logs : 2017-05-04 18:21:59.748 WARN 12188 --- [er[test.queue]] o.a.activemq.jms.pool.PooledSession : Caught exception trying rollback() when putting session back into the pool, will invalidate.

Re: OnApplicationEvent not called with CamelAutoConfiguration

Hi, I'm not sure that I follow what you're saying, but from what I observe using the JMS and SJMS components is that the connections get closed when the Camel consumer endpoints are closed. Also I see no way of destroying the ConnectionFactory (not in the public JMS API interface, nor in the

Re: Async bean method

Hi Morten, are you sure about this? Could it be that your own code is blocking the consumer. I just run a simple example with the file consumer and an bean processor returning CompletionStage. >From what I observe is that the consumer thread keeps polling the filesystem even if I sleep in the

Async bean method

Hi, I am trying to return CompletableFuture from my bean method in order to be able to consume more messages while processing while processing previous ones. However, I see no difference in behaviour. I seems the consumer thread is waiting for the future to complete. What is the purpose of the

Re: How to suspend a particular request and resume later

Perhaps there are good ways to do this technically, but in general I would avoid keeping state in your integration layer. It will just introduce you to a set of new problems when it comes to error handling and retry. You'd be better off redesigning the solution without the wait if possible. If

Re: ProducerTemplate thread waits indefinitely when messaging system (Tibco EMS) was down

Thanks for the information, I added all timeouts at my connection level. here is the connection code TibjmsConnectionFactory tibjmsConnectionFactory = new TibjmsConnectionFactory(); tibjmsConnectionFactory.setServerUrl(""); tibjmsConnectionFactory.setUserName("");

Re: How to suspend a particular request and resume later

In the given configurations i.e. Once I get this request back form waiting queue, I want to resume or start remaing configurations, which are responsible for creating an output file (i.e. given in split tag). Any help will be appreciated. Thanks & Regards Shikha Singhal -- View this

Camel kafka manual commit implementation

Hi Team, I want to implement Kafka manual commit using apache camel, but not able to find any clue to implement it its given only for auto commit. Kindly help me out in the issue. Thanks Abhijeet Shukla -- View this message in context:

How to suspend a particular request and resume later

Hi,I am receiving messages or requests from ActiveMQ and processing the messages and creating another output file with respect to each input request from ActiveMQ.My configurations are as given below:/ ${body}

Re: Camel kafka manual commit implementation

I am trying to do so using camel router as: from("kafka:{{kafka.hostname}}:{{kafka.port}}?topic={{kafka.topic}}={{kafka.consumer.groupid}}=none=false=3").process(new Processor() { @Override public void

When will camel exchange get garbage collected ?

I was trying to understand as to when camel exchange be eligible for garbage collection ? Or do we have to explicitly clear all the properties of the exchange before completing the route ? -- View this message in context: