Endpoint configuration error

Hi, I am creating a JmsEndpoint for my route. The problem is that when the JMS is down, the following line: JmsEndpoint endpoint=(JmsEndpoint)getContext().getEndpoint("activemq:topic:jms.topicName" is throwing exception. I have put this line in a try catch block but still I cannot catch the except

Re: Opposite of split

On Wed, Feb 27, 2013 at 11:38 PM, Jean Francois LE BESCONT wrote: > Hey all ! > > I have read the document by I have not really understand which component > should I use if I want to "unsplit" all message. I think that aggregate ( > and aggregate2 ) are their for that but I don't understand how to

Re: camel content enricher Aggregtation Strategy example error?

On Wed, Feb 27, 2013 at 11:07 PM, kingolego wrote: > The EIP Content Enricher page > has an example > implementation of an AggregationStrategy for use with an enrich(er). > > I believe the example's use of resource.getOut() may be incorrect.

Re: JPA Endpoint : Testing with Derby in-memory DB

On Wed, Feb 27, 2013 at 10:55 PM, shyenuganti wrote: > Here is my sample route. It is working fine with camel:run. I am able to read > from the DB. > > > from("oracleJpa://com.model.EventQueue?consumeDelete=false&consumer.delay=25000") > .id("OracleListener") > .to(

Re: Completion size question dynamic

On Thu, Feb 28, 2013 at 5:06 AM, Gvvenkat wrote: > I am using splitter with aggregator for processing a large file. So it is > hard for me to know no of splits the splitter produces feeding to the > aggregator. Since completion size one of key attribute for aggregator, how > can I work around thi

Completion size question dynamic

I am using splitter with aggregator for processing a large file. So it is hard for me to know no of splits the splitter produces feeding to the aggregator. Since completion size one of key attribute for aggregator, how can I work around this issue. Please advise Thanks in advance. -- Vi

camel-blueprint-test issues

I converted a test that was using the camel-test library to the camel-test-blueprint library and it appears that the route runs at least twice, but at the exact same time. I'm not sure why each route is being created more than once per test. I do see at the beginning of the test it print out that

Re: cxf response

For the jaxb stuff, see: "Partial marshalling/unmarshalling" on http://camel.apache.org/jaxb.html 2013/2/27 Smith-John : > I also tried it with generated JAXB classes from my wsdl/xsd and marshalling. > > But > from("cxf:cxfEndpoint?wsdlURL&dataFormat=PAYLOAD").unmarshal(jaxb).process(myProcessor)

camel content enricher Aggregtation Strategy example error?

The EIP Content Enricher page has an example implementation of an AggregationStrategy for use with an enrich(er). I believe the example's use of resource.getOut() may be incorrect. In actual use, the enricher (resource) Exchange has been "pi

JPA Endpoint : Testing with Derby in-memory DB

Here is my sample route. It is working fine with camel:run. I am able to read from the DB. from("oracleJpa://com.model.EventQueue?consumeDelete=false&consumer.delay=25000") .id("OracleListener") .to("log:{body}") .to("mock:JPAMock"); For testing t

Re: Need help converting a Spring queue definition to a Camel endpoint

The program wants to access the queues via jndi - and this is how you get jetty to expose those features using jndi. You don't have to use jndi of course, this was just as example for cases where that is desirable or needed. Best regards Ray Sent from my iPad On 27 Feb 2013, at 13:29, "naksh

Re: Packaging camel project (under Karaf)

Hi, you probably should try to build your own features file and use it in conjunction with the maven-karaf-features plugin to create your own pre-packaged Karaf distribution. Unfortunately since our change to svn-pub-sub the documentation disappeared I would have given you some direct links to the

Re: Packaging camel project (under Karaf)

Hi Martin, > On various environment, > there might be not a internet access at the moment, and for sure there will > be no chance to download our artifacts from our Maven. > So all of these have to prepackaged. What about creating local Maven repository? You can tell Karaf to read from any repo y

Re: Is there batch functionality in Camel?

Hi Ivan, > I wonder if the Spring Batch Component ( > http://camel.apache.org/springbatch.html) is proper to use in this case? You can use CamelItemReader to pass messages into Spring Batch. However I would say that your case is too simple to use Spring Batch for this purpose. I would advise to

Packaging camel project (under Karaf)

Hello guys, I'm wondering, how you are packaging yours Camel projects under Karaf? Sure, I found and used this: https://cwiki.apache.org/confluence/display/KARAF/6.2.+Custom+distributions Good thing, I'm able to create a tarball package. Actually, we need to package Apache Karaf, with all dependenc

Re: Is it possible to implement "Last value queue" using Camel?

Hi Paul, Last image caching for topics is part of the retroactive consumer feature of AMQ. It allows for topic consumers to travel back to the past without being durable subscribers. I didn't mention it because, as far as I understood your use case, you want the last message to be retained for ea

Problem polling UNIX FTP server

Hi, I'm new to Camel so I may have missed something obvious. I am using Camel 2.10.3, running on Windows 2003 server and Java 1.6. I am attempting to poll files from an FTP endpoint using the following URL: ftp:egate@devweb/camel_hosts/REMHOST_A/out?password=*&binary=true&localWorkDirecto

Re: Is there batch functionality in Camel?

you could use the Aggregator for that http://camel.apache.org/aggregator2.html Maruan Sahyoun Am 27.02.2013 um 18:19 schrieb Ivan Vasilev : > I wonder if the Spring Batch Component ( > http://camel.apache.org/springbatch.html) is proper to use in this case? > > Ivan

Re: Is there anyway to configure the JPA component to get it's query (or query parameters) from an inbound message?

I figured out how to do it. If anyone is interested, I can supply details. On Wed, Feb 27, 2013 at 10:54 AM, Chris Wolf wrote: > I ask because I want the query to be parameterized by the results of > up-stream component executions. > > Thanks, > > > Chris

Is there batch functionality in Camel?

Hi All, I wonder if I can set messages from/to some endpoint to be sent on batches. I need this because the total time for sending messages one by one in some cases is far bigger than packing say 1k messages and sending them at once. For example if I have the following code: from("file://inputdir

Is there anyway to configure the JPA component to get it's query (or query parameters) from an inbound message?

I ask because I want the query to be parameterized be the results of up-stream component executions. Thanks, Chris

Re: cxf response

Thx Willem. @Christian Mueller: No I have no problems to implement it. I just wanted to know if I have to wrap the response into a xml document by myself or if camel does this for me. -- View this message in context: http://camel.465427.n5.nabble.com/cxf-response-tp5728106p5728234.html Sent fr

RE: Is it possible to implement "Last value queue" using Camel?

What about implementing LVQ activemq plugin? http://activemq.apache.org/developing-plugins.html Here are a bunch of examples: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/util/ http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src

Re: Invoking a static bean method in my camel xml

Yes, it's not very well documented. Here is an example: in the middle of a route I do: which will replace the body after the step in the route with the substring 150 chars into the incoming payload. 2013/2/27 bikehead : > Is it possible to invoke a static method to a class within my camel.xml

Re: camel processor in InOut to send 2 replies

Hi Hadrian, thanks for your reply. Sorry if I've been unclear. The messages I am publishing to the In queue have JMSReplyTo header set. As you suggested I've used the reply to header to send an additional message using a bespoke producer in the process method of the Processor: javax.jm

Invoking a static bean method in my camel xml

Is it possible to invoke a static method to a class within my camel.xml configuration? For example I'd like to do something like: Googleing shows an example of java route builder doing the equivilant of: .bean(org.apache.log4j.MDC.class, "put('dpservices.storyKey', ${body.urlKey})" when buiding

Re: Spring-ws producer endpointMapping

On Wed, Feb 27, 2013 at 1:42 PM, anaCortes wrote: > any idea about how to add an endpointMapping to a spring-ws producer? ;) > I suggest to check the source code and see what is possible. Maybe its doable, or an improvement is needed in the component to support what you want. > > > -- > View th

Re: Split an empty list

Just a proposal : it might be great to write in the documentation a post about how to manage the ".end()" instruction : what components need it? how two not "cross" them and avoid confusions? Like in : .loop(3) .to(...) .split(...) .end() --> what END is it? - http://developpef.blogspot.c

Re: Split an empty list

OK, after a test, you're right, it is now working as expected. Thanks for pointing me this tip! - http://developpef.blogspot.com -- View this message in context: http://camel.465427.n5.nabble.com/Split-an-empty-list-tp5728214p5728225.html Sent from the Camel - Users mailing list archive at

Re: Split an empty list

Hi Yes its this eip http://camel.apache.org/composed-message-processor.html The Camel splitter has a built-in aggregation stragegy which is much easier to use than split + aggregate. See the example on the page above, about using ONLY splitter. On Wed, Feb 27, 2013 at 1:28 PM, developpef wrote

Re: Spring-ws producer endpointMapping

any idea about how to add an endpointMapping to a spring-ws producer? ;) -- View this message in context: http://camel.465427.n5.nabble.com/Spring-ws-producer-endpointMapping-tp5728172p5728223.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Split an empty list

Well, after my SPLIT I use an aggregation Strategy with completionPredicate to Exchange.SPLIT_COMPLETE. So if I understand, I would rather write : .split(body(), myAggregationStrategy) (... split operations ...) .end() rather than : .split(body()) (... split operations ...) .aggregate(...) .com

Re: Quartz component support for storing schedule in database rather than in-memory

On Wed, Feb 27, 2013 at 12:43 PM, gilboy wrote: > Hi > > I just wanted to confirm that the quartz component does not support storing > the schedule in the database rather than in-memory > What do you mean? Can you be more specific what you mean by storing "schedule" You can configure the quartz

Re: Split an empty list

On Wed, Feb 27, 2013 at 11:46 AM, developpef wrote: > Hello, > > Here is what happens : > > My route is : > > from("direct:inside") > .log(LoggingLevel.INFO, " start") > .beanRef(MY_SERVICE, "retrieveDataList") > .log(LoggingLevel.INFO, " before split ${body}") > .split(body()) > .log(Logg

Re: camel-quickfix RequestReplyExample java.io.IOException

On Feb 27, 2013, at 3:12 AM, "Babak Vahdat [via Camel]" wrote: > Hi Steve > > Thanks for looking into this. Unfortunately the provided patch causes > regressions by some pre-existing tests of this component. I've provided the > details of this into the ticket itself, so let's continue the c

Split an empty list

Hello, Here is what happens : My route is : from("direct:inside") .log(LoggingLevel.INFO, " start") .beanRef(MY_SERVICE, "retrieveDataList") .log(LoggingLevel.INFO, " before split ${body}") .split(body()) .log(LoggingLevel.INFO, " after split ${body}") And my logs : |2013-02-27 11:

Re: camel-quickfix RequestReplyExample java.io.IOException

Thanks Steve! Very appreciated! Best, Christian Sent from a mobile device Am 26.02.2013 17:39 schrieb "stevebate" : > > On Feb 25, 2013, at 2:21 PM, Babak Vahdat [via Camel] < > ml-node+s465427n5728116...@n5.nabble.com> wrote: > > As I did *not* backport the fix for CAMEL-5861 to this branch (be

Problem with donefilename on sftp.

Hi all, i have a problem when writing donefilename on sftp. (Camel version 2.10.3) I tried some possibilities in my route : 1) .to("sftp://camel@port-jogu?password=xxx&fileName=test.csv&doneFileName=test.done";) All two files are written, but not in the place i wanted. 2) .to("sftp://camel@port

Re: A little problem with annotation @CsvRecord

Thanks @Ib it works in a better clean way with your method ! 2013/2/26 lb [via Camel] > You may use the following syntax: .unmarshall().bindy(BindyType.Csv,Your > Class.class) > > Bear in mind that the current implementation does scan the package of the > viventi class thus you should not hav

Re: camel-quickfix RequestReplyExample java.io.IOException

Hi Steve Thanks for looking into this. Unfortunately the provided patch causes regressions by some pre-existing tests of this component. I've provided the details of this into the ticket itself, so let's continue the conversation inside JIRA itself to avoid making noise here @ the user forum. And