RE: Jsch issue with compression algorithm

HI Williem, Camel , JSch Developers I need compression to be set on the route as the remote server only offers "zlib" as the compression algorithm. As I mentioned below, when compression option is set on camel route, SftpOpertions does the below - // compression if (sftpConfig.

Re: Quartz job data deletion in clustered quartz2

We are setting the camel Context id in the blueprint xml and have deployed it to the osgi environment. Eg: Then we get misfires when other VM's in the cluster try to do load balancing of the trigger : No CamelContext could be found with name: *572-Quartz2_Mig_Test1* . Why is the osgi bundle i

Aggregator recover checker producing duplicate messages

Hi, We are using camel 2.12.3 Aggregator pattern with JDBC backend repository. We are seeing an issue with duplicate messages being generated by the recovery checker thread. Looking at the debug level logs, it seems like the timeout checker processes messages and moves the aggregated message to t

Re: Difference between bean(MyObject.class) and bean(new MyObject())

The second parameter of bean(Object, String) is for looking up the Object method. "parse(${body[title]}, ${body[thumbnail][path]}, ${body[prices][0][price]}, ${body[id]})” cannot help camel to look up right method to use. My suggestion is you can just pass the body object to the parse method dir

Re: can camel throttle messages based a dynamic message key?

Niels, I think what you are looking for is not throttling, but single threading groups of related messages, correct? If so, then ActiveMQ message groups is designed for exactly that and is trivial to implement... Just route your messages through a JMS queue and set the JMSXGroupId header set to y

Consuming from an External WS given only the External WS WSDL definition

Is there a way to connect from Camel to an external web service given only the address of the external ws wsdl definition. I have found a number of examples using Camel-CXF which can connect to an external ws but in all cases the serviceClass is defined as part of the definition of the ClientProxyF

Re: Aggregate up to N "ASAP"

bacar, as suggested...use a completionTimeout value greater than 0...this will complete when a max size of 100 is reached OR after no new messages are received for that amount of time...whichever is FIRST... also, if you have a max delay requirement, then use the completionInterval() instead to gu

Re: Aggregate up to N "ASAP"

Timeout=0 is the very essence of what I'm trying to express, I'm not sure how I can be both "correct" and "making no sense" :-) I'd have guessed this was a common use case and would be a useful feature.  Consider a processor posting to a seda which consumes messages and posts them in batch t

Re: Not all processors are listed in JMX, preventing detailed route statistics/profiling

Claus Ibsen-2 wrote > You can enable DEBUG logging for > org.apache.camel.management. And it should log when it enlists a > processor as MBean. Maybe you can see if the missing processors at > least is DEBUG logged. Claus, I enabled DEBUG for org.apache.camel.management as you requested. There i

Possible issue with FileLockExclusiveReadLockStrategy leaves orphaned .camelLock file.

I am trying to understand this block of code in the catch clause of the FileLockExclusiveReadLockStrategy acquireExclusiveReadLock() method: } catch (IOException e) { // must handle IOException as some apps on Windows etc. will still somehow hold a lock to a file //

Re: Aggregate up to N "ASAP"

And, of course, time out, set to 0, makes no sense... -- View this message in context: http://camel.465427.n5.nabble.com/Aggregate-up-to-N-ASAP-tp5758134p5758140.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Aggregate up to N "ASAP"

Hello, Baris! I'm afraid, you are asking to find a better solution for 2 x 2 = 4 problem. Your solution is right. I would do it the same way. More over, here's an example from book "Camel in Action" by Claus Ibsen: public void configure() throws Exception { from("direct:start") .log("Sending ${

Re: Aggregate up to N "ASAP"

Hi Baris, > Is there a way to aggregate the first 100 messages from a seda if >=100 are > available, but just take however many are available if there are fewer? As aggregating messages is a process, not a moment in time, you need to specify some completion timeout duration. Too short timeout doe

Aggregate up to N "ASAP"

Hi, Is there a way to aggregate the first 100 messages from a seda if >=100 are available, but just take however many are available if there are fewer? I think I want aggregate(...).completionSize(100).completionTimeout(0), ie complete on 100 items or 0, whichever condition is met "first", but I'

Re: can camel throttle messages based a dynamic message key?

Hi No the throttler does not support different groups of messages to throttle differently. On Thu, Oct 16, 2014 at 4:04 AM, nbertram wrote: > I have a route that is invoked to get a status of an object "foo". The > instance of foo is identified by a key. > > Concurrently at any given time I ma

Re: Questions about doneFileName

Hi See http://camel.apache.org/file-language.html You should use: doneFileName=${file:name.noext}.ready On Mon, Oct 20, 2014 at 10:53 AM, BURN, James wrote: > Sorry I should add, this is using ServiceMix 5.3.0 and camel 2.13.2 > > Cheers > J > > -Original Message- > From: BURN, James [m

Re: Private variables not being inspected camel-swagger

On Tue, Oct 21, 2014 at 9:12 AM, panzerhans wrote: > I I expose this class: > > @ApiModel(value = "MyDTO ", description = "My data transporter") > public class MyDTO { > @ApiModelProperty(value = "This is a private field") > private String myPrivateField; > } > > Swagger will not document

Re: Webdav

Hi There is no webdav component. But years ago there was talk about such component, but we never got around implementing one. I dont think the community has requested webdav in recent years. There is a JIRA ticket about webdav you may be able to find that, and find more details. There was also so

Re: Difference between bean(MyObject.class) and bean(new MyObject())

Hi Henrik This is my Git repo : https://bitbucket.org/jvila/kata-marvelkata Thank you El 27/10/2014 18:58, "Henryk Konsek" escribió: > Hi Jonathan, > > > But if I simple replace the bean line with bean(new ComicBuilder(), > ) > > then it works without putting the log command before. > > No

Re: How to split to files and add number to output file names (not overwrite)

Hi Yes you can control the file name to use for writing the file. See more details at http://camel.apache.org/file2 http://camel.apache.org/file-language.html On Mon, Oct 27, 2014 at 6:12 PM, dermoritz wrote: > I have a route that splits large files into smaller ones. All split files > should be

Re: camel-jms consumer 2.14.0 on JBOSS EAP 6.1.1. connectionFactory must be specified

Not sure what the problem is, after a couple of refreshes and builds it worked. Looks like a environment related issue (Eclipse, Maven) -- View this message in context: http://camel.465427.n5.nabble.com/camel-jms-consumer-2-14-0-on-JBOSS-EAP-6-1-1-connectionFactory-must-be-specified-tp5758089p5

Re: Difference between bean(MyObject.class) and bean(new MyObject())

Hi Jonathan, > But if I simple replace the bean line with bean(new ComicBuilder(), ) > then it works without putting the log command before. No real difference between bean(Foo.class, "method") and bean(new Foo(), "method") I'm aware of. Small Maven example reproducing the issue will be usef

Re: camel-rabbitmq only receive one message when autoAck is false

anybody can help? Thanks, Jeffrey -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-only-receive-one-message-when-autoAck-is-false-tp5758034p5758121.html Sent from the Camel - Users mailing list archive at Nabble.com.

[RESULT][VOTE] Release Apache Camel 2.12.5 - second try

The vote passes with: [7] +1 (jgenender, joed, cmueller, ningjiang, cschneider, janstey, hadrian) [1] +1 - non-binding (jbonofre) [0] -1 I will proceed with publishing the artifacts later today, if the Nexus repo is accessable again and make public announcement of the release tomorrow, after the m

Difference between bean(MyObject.class) and bean(new MyObject())

Hello I have a route : from("http://gat...URLd805d";). unmarshal().json(JsonLibrary.Jackson). split(simple("${body[data][results]}")). bean(ComicBuilder.class, "parse(${body[title]}, ${body[thumbnail][path]}, ${body[prices][0][pr

How to split to files and add number to output file names (not overwrite)

I have a route that splits large files into smaller ones. All split files should be written to same directory. The default behavior of file endpoint (producer) seem to overwrite always. Is there an easy way to let the file producer do a simple rename by adding a counter to file name? Like in OS if

Re: Putting some Map values into a Bean

Hello Thanks to the help of Christian..now it works : from("http://gateway.m...URL.805d";). unmarshal().json(JsonLibrary.Jackson). split(simple("${body[data][results]}")). * bean(new ComicBuilder(), "parse(${body[title]}, ${body[thumbnail][pa

Forcing Camel to use synchronous processing

Hi guys, according to the Asynchronous routing engine documentation page Camel can be forced to use synchronous processing via the synchronous=true option. The DefaultEndpoint

Re: ActiveMQ InOut JMS messaging with external system

Have a look at [1]. [1] https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java;h=84b20a28fc73da7ff55ff4ad61dde64f2ed8ceb3;hb=HEAD Best, Christian -- View this message in context: http://camel.465427.n5.nab

Re: How to act as TCP-client with Camel + Mina/Netty?

Why not just using camel-mina or camel-netty ? I didn't read the original message. So I will get back to you with more details in a couple of days. Regards JB Sent from my Samsung Galaxy smartphone. Original message From: "Morgan.Hautman" Date:27/10/2014 15:57 (GMT+01:0

Issue with adding wsse:security header in Apache Camel Route

I am using camel: 2.12.1 spring: 4.0.5.RELEASE CXF : 2.7.13 My goal is to deliver a soap message with wsse:security header(as mentioned below) in Payload mode from my camel router to some endpoint. http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd"; xmlns:wsu="ht

camel-jms consumer 2.14.0 on JBOSS EAP 6.1.1. connectionFactory must be specified

Hi All, I'm facing an issue with a jms consumer endpoint. The deployment fails due with a exception *java.lang.IllegalArgumentException: connectionFactory must be specified* The route below fails on startup. However, the jms producer endpoint does not complain about connection factory. *JMS C

Re: Using named query parameters

Hi Claus, I'm still not sure if the way I'm trying to access the java.util.Map resultset with :#Position is the right way. It seems that nobody is using this feature at all (at least I cannot find any other samples on the internet). -- View this message in context: http://camel.465427.n5.nabb

Re: camel-jms consumer 2.14.0 on JBOSS EAP 6.1.1. connectionFactory must be specified

It works when I add the *connectionFactory* option to the route, but my question is even though the jms component is initialized with JmsConfiguration containing the ConnectionFactory, why is the consumer expecting the connectionFactory option on the endpoint again? ===Consumer Route=

Re: Zookeeper component RoutePolicy

Hi Henryk, thanks for your quick reply. I just tested it like your said. Basically in both instances I configured the zookeeper route policy with enabledCount = 2. The problem with this approach is that both masters will consume the message. What I want is to know if it is possible to when mess

Putting some Map values into a Bean

Hello I want to get some fields from a Map structure and put those fields into a Bean. I have this code : from("http://URL to a REST service that returns a JSon ..."). unmarshal().json(JsonLibrary.Jackson). split(simple("${body[data][results]}")).

Re: How to act as TCP-client with Camel + Mina/Netty?

Hello, Is there any update on this? I may be considering contributing if it's isn't. Morgan -- View this message in context: http://camel.465427.n5.nabble.com/How-to-act-as-TCP-client-with-Camel-Mina-Netty-tp5718671p5758101.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Change property in unit test

Hi Claus, I am using plain spring testing and annotating my custom class like this: @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration public class MyCamelTest { I don't think I am able to use useOverridePropertiesWithPropertiesComponent in this scenario. Is there a similar technique I

Re: Camel Mail CC and BCC headers

Thanks Willem, Looks great. -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Mail-CC-and-BCC-headers-tp5757943p5758097.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Zookeeper component RoutePolicy

Hi Marco, > Though I would like to configur it to have > more than one master running and to do something similar to a load balancer > through the nodes. Is there any way to do it? The ZooKeeperRoutePolicy constructor takes enabledCount as a second argument: int enabledCount = 2; new ZooKeeperRo

Re: ActiveMQ InOut JMS messaging with external system

Update: Just for testing, I tried sending the same message back in the response and it worked fine. But If I'm creating a new ActiveMQMapMessage and set following: ActiveMQMapMessage responseMapMessage = new ActiveMQMapMessage(); //(I also tried copying original message and setting below properti

Re: Using named query parameters

Hi Yeah sounds like we should validate in camel that the key exists. You are welcome to log a JIRA ticket http://camel.apache.org/support On Mon, Oct 27, 2014 at 11:46 AM, Router wrote: > Is it a bug? > > Under http://camel.apache.org/sql-example.html at the very bottom it says: > > Notice in

Zookeeper component RoutePolicy

Hi, I was able to configure the zookeeper component to work in a master/slave fashion way (using route policy). Though I would like to configur it to have more than one master running and to do something similar to a load balancer through the nodes. Is there any way to do it? Thanks in advance,

Re: Simple and easy REST client with Camel

Stream caching is described here : http://camel.apache.org/stream-caching.html On Mon, Oct 27, 2014 at 12:41 PM, Jonathan Vila Lopez < jonathan.v...@gmail.com> wrote: > Hi Charles > > You are right. thank you a lot. > > Is that explained in any documentation page ? to read the source. > >

Re: Simple and easy REST client with Camel

Hi Charles You are right. thank you a lot. Is that explained in any documentation page ? to read the source. Kind regards. [image: Inline image 2] * Jonathan Vila** * * jonathan.v...@gmail.com *

Re: Using named query parameters

Is it a bug? Under http://camel.apache.org/sql-example.html at the very bottom it says: Notice in the SQL queries below we use named parameters which must start with prefix ':#' and then the name, eg :#amount. Then Camel will bind that parameter with the given name, from the message body (if its

Re: Simple and easy REST client with Camel

Your syntax is not correct as umarshalling of a jackson stream (coming from the HTTP request) will return a HashMap. To access to this value using the simple language, this syntax has to be used : simple("${body[code]}") Example : http://gateway.marvel.com/v1/public/comics?da

Re: Simple and easy REST client with Camel

You syntax is not correct as unmarshalling of jackson will return On Mon, Oct 27, 2014 at 10:56 AM, Jonathan Vila Lopez < jonathan.v...@gmail.com> wrote: > Hi Charles > > Oki, thank you. > > But, how can I retrieve 3 attributes from the JSON and print out them ? In > the line 3 I get nothing in t

Re: Dozer Type Conversion (2.12.2) not working in Karaf

Hi Try with latest release as the older dozer release does not work well in OSGi. And we also fixed stuff in camel-dozer. So try with Camel 2.14.0. On Mon, Oct 20, 2014 at 5:56 PM, Thomas Weinschenk wrote: > Hi all, > > I tried to use the Dozer Type Conversion as explained in the documentation >

Re: camelContext.hasEndpoint() returns null when endpoint (apparently) exists

Thank you Claus, I'm doing some tests but what you said has to be the problem. I have routes that many times per day use the consumerTemplate for reading files (each file = one endpoint), so these endpoints must have been updating the endpoint cache periodically. I fear that in this case increas

Re: Simple and easy REST client with Camel

Hi Charles Oki, thank you. But, how can I retrieve 3 attributes from the JSON and print out them ? In the line 3 I get nothing in the console, so it seems line 2 in wrong in some way 1. ​ unmarshal().json(JsonLibrary.Jackson). 2. setBody(simple("my attributes are : ${body?.code?}")). 3.

Re: Simple and easy REST client with Camel

Hi Jonathan, Our documentation is not longer up to date as now the http component proposes / provides also a HttpConsumer (= Polling Consumer) which is able every x second to do a HTTP request. So, you can also use this syntax within your Apache Camel route (from("http://";).to("") to poll a HTTP

Re: Camel Mail CC and BCC headers

Hi, I just create a JIRA[1] and submitted a quick fix for it. Please feel free to verify it by using latest Camel 2.15-SNAPSHOT. [1]https://issues.apache.org/jira/browse/CAMEL-7966 -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://

Re: camel-rabbitmq logging exceptions as debug

opened https://issues.apache.org/jira/browse/CAMEL-7967 thanks -- View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-logging-exceptions-as-debug-tp5757936p5758069.html Sent from the Camel - Users mailing list archive at Nabble.com.

Log in- and outbound camel http messages

Hi, Actually I would like to do a simple thing. Log all incoming and outgoing HTTP Message to a database. However, even camel seems to be the right choice, it is not so simple to do it. I read the documentation, but could not find any simple solution for this. So far my solution is the following:

Re: Simple and easy REST client with Camel

Hello Charles But, with that code I used I successfully get the response and successfully unmarshals it.. in fact, in my code my problem was in the line of setBody I can not get the attributes. Anyway I will try your proposal. Kind regards. [image: Inline image 2] * Jonathan Vila*

Re: Documentation for JEE Transaction Handling in Camel needed

Hi As you use MDB then its the app server that manages the transaction and does the TX start | commit | rollback. So you should look at the documentation of the app server how this works / jee spec etc. On Fri, Oct 17, 2014 at 3:45 PM, wrote: > Hi, > > our application run in JBoss EAP 6.1 and u

Re: ReportIncident tutorial - Logging Issue..

OK - i have found a few other issues with the tutorial due to API changes, so will log a ticket. Thanks VM for the link. > On 27 Oct 2014, at 06:56, Claus Ibsen-2 [via Camel] > wrote: > > Hi > > That tutorial is very old, though you have discovered a little bug. So > feel free to log a JI

Re: camel-rabbitmq logging exceptions as debug

Hi Yeah that sounds like we should improve this. Feel free to log a JIRA ticket http://camel.apache.org/support On Thu, Oct 23, 2014 at 11:08 AM, Marco Crivellaro wrote: > Hi, > I am using Camel 2.14.0 > Connecting to RabbitMQ using camel-rabbitmq I've noticed that no ERROR is > logged if the co

Re: camelContext.hasEndpoint() returns null when endpoint (apparently) exists

Hi Maybe you hit the upper limit on the endpoint cache. You can set a higher endpoint cache size http://camel.apache.org/how-do-i-configure-the-maximum-endpoint-cache-size-for-camelcontext.html Though we should likely improve Camel to keep the endpoints from the routes in the cache as they are i

Re: Simple and easy REST client with Camel

Hi Jonathan, To call the HTTP Server exposing the REST service the HTTP producer must be used and not the HTTP Consumer component of Camel ( http://camel.apache.org/http.html). This syntax is not correct (from("http://";) while this one is correct from("direct:marvel").to(" http://gateway.marvel.

Re: Not all processors are listed in JMX, preventing detailed route statistics/profiling

On Fri, Oct 17, 2014 at 6:39 PM, BlackTie wrote: > I am using hawtio as a standalone WAR, and did some research about accessing > jolokia through hawtio. Browsing through the info that jolokia retrieves > from JMX, not all the processors are listed. I added the maxObjects query > param (with a v

Re: Web service SOAP fault handling

Looks like u want to process the metadata of the exceptions Then it might be easier to Check docs for the standard exchange properties to which the exception details are mapped when one is thrown. On 27/10/2014 9:44 am, "Jshaan51" wrote: > Hi ABouchama, > > It's not about responding with SOAP f