Re: Transactional aggregator

2013-01-08 Thread orz
Hi, Thanks for your reply. I have already read chapters 8 and 9. I understand that I can use HawtDBAggregationRepository and redirect the aggregated exchange(s) to a DLQ after a certain number of retries. However, that is not what I want. I need it to behave like the following steps 1. Message A

RecipientList with delimiter argument

2013-01-08 Thread liugang
Hi All: When I plan to use recipientList component, I can only select one from: Method 1: public RecipientListDefinition recipientList(Expression recipients) {...} Method 2: public RecipientListDefinition recipientList

Re: Polling consumer does not stop when pollStrategy specified

2013-01-08 Thread Willem jiang
Can you check if the files are pulled already? If there is no new file to be pulled, the stream:out will not print any things out. -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http

Re: recipientList with POST and request body

2013-01-08 Thread Willem jiang
Hi, I'm afraid the recipientList will not meet your needs at this time. As you need to change the Http method and request JSON body dynamically, current recipientList just supports to change the Camel Endpoint URI dynamically. So I suggest you to leverage the ProducerTemplate[1] in your custome

Re: repeating the steps from the route

2013-01-08 Thread Christian Müller
We have a loop() in our DSL... Sent from a mobile device Am 08.01.2013 21:46 schrieb "Kesireddy, Chandana (ITD)" < chandana.kesire...@state.ma.us>: > Following is the route : > > public class MyRouteBuilder extends RouteBuilder { > @Override > public void configure() throws Exception { >

Re: SSH - BouncyCastle

2013-01-08 Thread Christian Müller
Which version of BouncyCastle? What is your runtime? Can you share the complete stack trace? Sent from a mobile device Am 08.01.2013 15:34 schrieb "Leandro Franchi" : > Hi, > > I'm using apache camel 2.10.2 and getting the follow error when try to > use ssh component consumer. > > > java.lang.NoC

CamelOne

2013-01-08 Thread Jason Chaffee
Does anyone know if there is going to be a CamelOne Conference this year? Jason

repeating the steps from the route

2013-01-08 Thread Kesireddy, Chandana (ITD)
Following is the route : public class MyRouteBuilder extends RouteBuilder { @Override public void configure() throws Exception { // xnc route here String xncFileSupport = ICEndPoints.getValue(XNC_FILE_SUPPORT); if (XNC_SUPPORT_ON.equalsIgnoreCase(xncFileSupport)) { try { InProce

recipientList with POST and request body

2013-01-08 Thread Zemin Hu
Hi, I need to send request to a dynamically constructed URL list which provides RESTful web services. So my simplest need is to send POST requests with fixed JSON body, later I may need to construct different JSON body for each URL in the list as well, and since it's RESTful service, DELETE/PUT ar

Re: Polling consumer does not stop when pollStrategy specified

2013-01-08 Thread babu.sona2001
Sorry.. I take that back. camelContext.stopRoute() stops the route. But then, if I call camelCOntext.startRoute(), only the file polling is started. It does not print anything in console. What happens to stream:out? -- View this message in context: http://camel.465427.n5.nabble.com/Polling-cons

Re: Unable to consume syslog messages

2013-01-08 Thread sscott
sscott wrote > I set up rsyslogd to forward *.* to localhost:5140. Every log message > causes Camel to output an InvalidPayloadException caused by a > NoTypeConversionAvailableException with the detail "No type converter > available to convert from type: > org.jboss.netty.buffer.BigEndianHeapChann

Re: Problem with calling a simple POJO after a route

2013-01-08 Thread Meriem
I tried with : CamelContext context = new DefaultCamelContext(); context.addRoutes(new MyRouteBuilder()); context.start(); Thread.sleep(1000); context.stop(); System.out.println("End of the program"); and it worked. Thank you very much for your help. Bests, Meriem. -- View this message in co

SSH - BouncyCastle

2013-01-08 Thread Leandro Franchi
Hi, I'm using apache camel 2.10.2 and getting the follow error when try to use ssh component consumer. java.lang.NoClassDefFoundError: org.bouncycastle.crypto.prng.VMPCRandomGenerator The jdk version is: 1.7.0_05. I've try to declare bouncycastle dependency on pom without success. Thanks -

Re: Problem with calling a simple POJO after a route

2013-01-08 Thread Claus Ibsen
On Tue, Jan 8, 2013 at 3:11 PM, Meriem wrote: > Thank you very much for your reply. > But how can I stop camel automatically? my program should execute a route > (for example copiying files) and continue with something else that has > nothing to do with camel. In fact, I'm using Struts web applica

Re: how to break out of a batch?

2013-01-08 Thread Claus Ibsen
On Tue, Dec 4, 2012 at 2:57 AM, Willem jiang wrote: > I think we could add some feature on the ScheduledPollConsumer to stop > processing the message if some kind of flag is set. As current implementation > doesn't check if there is some exception is thrown when processing the > exchange. > I

Re: camel-mail

2013-01-08 Thread Claus Ibsen
Hi See for example http://camel.apache.org/walk-through-an-example.html On Tue, Jan 8, 2013 at 2:51 PM, Claus Ibsen wrote: > On Tue, Jan 8, 2013 at 2:48 PM, tamil13 wrote: >> >> Yes. We included *real mail server* detail only. This is same code except >> configuration information. >> Below cod

Re: camel-mail

2013-01-08 Thread Claus Ibsen
On Tue, Jan 8, 2013 at 2:48 PM, tamil13 wrote: > > Yes. We included *real mail server* detail only. This is same code except > configuration information. > Below code return null pointer exception also. > Is there any other code available to create and send mail using *smtp* > component? > And di

Re: camel-mail

2013-01-08 Thread tamil13
Yes. We included *real mail server* detail only. This is same code except configuration information. Below code return null pointer exception also. Is there any other code available to create and send mail using *smtp* component? -- View this message in context: http://camel.465427.n5.nabble

Re: Problem with calling a simple POJO after a route

2013-01-08 Thread Claus Ibsen
Hi On Tue, Jan 8, 2013 at 2:38 PM, Meriem wrote: > Hi, > I'm triying to run a route and do something else after (calling a POJO or > just printing something); with the following code : > Main main = new Main(); > main.enableHangupSupport(); > main.addRouteBuilder(new MyRouteBui

Re: Camel websocket disconnect trigger

2013-01-08 Thread Claus Ibsen
On Sat, Jan 5, 2013 at 7:56 AM, Willem jiang wrote: > Hi, > > Current Camel websocket manage the web socket connection itself with the > MemoryWebsocketStore. I'm not sure what kind of resource you need to manage > yourself. > > You should be able to know if the client web socket disconnect if y

Problem with calling a simple POJO after a route

2013-01-08 Thread Meriem
Hi, I'm triying to run a route and do something else after (calling a POJO or just printing something); with the following code : Main main = new Main(); main.enableHangupSupport(); main.addRouteBuilder(new MyRouteBuilder()); main.addRouteBuilder(new MyRouteBuilder2());

Re: camel-mail

2013-01-08 Thread Claus Ibsen
Hi Welcome to the community. The code below is from an unit test, which uses a mock mail server (not a real mail server). In your scenario, you should change the details to a real mail server (in case you want to send the emails for real). On Tue, Jan 8, 2013 at 2:28 PM, tamil13 wrote: > > Hi.

camel-mail

2013-01-08 Thread tamil13
Hi. I am new to camel. just finished studying 'camel in action' book. but There is no mail configuration information in it. Using camel, I want to send a mail using *smtp* component. I tried everything as much as possible. but There is no progress. All I need is I want to create a new message, set

Re: Transactional aggregator

2013-01-08 Thread Claus Ibsen
Hi If you got the Camel in Action book by any chance then check out chapter 8 and 9 first. Then you should have a better understanding of this. On Tue, Jan 8, 2013 at 11:51 AM, orz wrote: > The Spring DSL is something like the following: > > > > > > > > > org.apach

Re: Transactional aggregator

2013-01-08 Thread orz
The Spring DSL is something like the following: org.apache.camel.component.http.HttpOperationFailedException true

Re: OnException Problem

2013-01-08 Thread Claus Ibsen
Hi > onException(Exception.class).process(new MyFunctionFailureHandler()).stop(); The .stop() does not stop the program. It stops continue routing the message. Though that is implied when you use onException anyway. See this FAQ http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html

OnException Problem

2013-01-08 Thread kikou1984
Hi, I followed this exemple on camel site. "http://camel.apache.org/exception-clause.html";. I want to catch all Exception and stop the program when the first Exception is catched. Here the main program : ** public void configure(){

Re: Polling consumer does not stop when pollStrategy specified

2013-01-08 Thread Claus Ibsen
Hi There is API on CamelContext to stop routes by its id camelContext.stopRoute("routeId"); On Tue, Jan 8, 2013 at 9:06 AM, babu.sona2001 wrote: > I have as follows. I want to stop it, modify and start it. > > from('file://D:/temp/20130801/inbound?pollStrategy=#errorHandlerService') > .rou

Polling consumer does not stop when pollStrategy specified

2013-01-08 Thread babu.sona2001
I have as follows. I want to stop it, modify and start it. from('file://D:/temp/20130801/inbound?pollStrategy=#errorHandlerService') .routeId("routeId") .to("stream:out") My pollStrategy looks like: class ErrorHandlerService extends DefaultPollingConsumerPollStrategy { } The followin