Live updates via the Atom Consumer

it should not wait for the next poll to receive the data but instead fetch it the moment the data is published on the atom service. Please let me know how can I do this? Thanks, Richa -- View this message in context: http://camel.465427.n5.nabble.com/Live-updates-via-the-Atom-Consumer-tp5768390

Error while polling an Atom Feed

:615) at java.lang.Thread.run(Thread.java:745) JBoss 7.1.3.Final-redhat-4 is stopping... At times, this work, at times, it doesn't. Can someone please let me know, what I am doing wrong here. Thanks, Richa -- View this message in context: http://camel.465427.n5.nabble.com/Error-while-polling-an-Atom

ActiveMQ topic as input endpoint in Apache Camel

then sleeps. Can someone tell me if there is some issue with the configuration of the jms endpoint? Thanks, Richa -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-topic-as-input-endpoint-in-Apache-Camel-tp5753957.html Sent from the Camel - Users mailing list archive at Nabble.com.

Error handling in aggregation strategy

the onException blocks. Can someone help me in handling the exceptions that occur in the aggregation strategy? Thanks, Richa -- View this message in context: http://camel.465427.n5.nabble.com/Error-handling-in-aggregation-strategy-tp5753876.html Sent from the Camel - Users mailing list archive at

Set rest service headers for querying

am able to set the query parameters but not the headers. Can someone please tell me how to set the headers in CxfRsEndpoint? Please help me with this problem. Thanks, Richa Amadeus Software Labs Pvt. Ltd. -- View this message in context: http://camel.465427.n5.nabble.com/Set-rest-service

Re: Camel JMS monitoring

I would also like to know if we can use hawtio project for commercial use. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-JMS-monitoring-tp5745429p5745467.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel JMS monitoring

Thanks claus. The hawtio project is really nice and easy to use. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-JMS-monitoring-tp5745429p5745464.html Sent from the Camel - Users mailing list archive at Nabble.com.

Camel JMS monitoring

Hi, I have a camel route for which I want to enable monitoring. I have added the following code to enable monitoring: System.setProperty("org.apache.camel.jmx", "true"); context.getManagementStrategy().getManagementAgent().setServiceUrlPath("/route/monitoring"); context.getManageme

Re: Parallel copy of files from FTP location.

Yes it does copy all the files from source to destination but it is done one by one. So unless one file is processed, the another won't be copied. I need to know a way where multiple files can be copied at once so that i can use threads for multiprocessing. -- View this message in context: htt

Parallel copy of files from FTP location.

Hi, I have a camel route that reads files from FTP location, does some processing and then sends the files to output location. I am using a locaWorkDirectory in the FTP url. For now, at a time one file is copied to the local work directory, processed and then sent to the output location. Is there

Camel Unmarshal throwing heap space exception

Hi, I have a camel route where I am dealing with huge CSV files which comes in gzip format. The route looks as follows: from(inputLocation) .unmarshal().gzip() .unmarshal().csv() .process(someProcessor) .to(outputLocation) This route works fine with small files but when I use huge files, it thro

Re: FTP endpoint failure

I want to set the maximum number of retries and after the retries I want to shut down my route. I cannot do it now because the control never goes to the onException block as the FTP never throws exception when it is an input endpoint. -- View this message in context: http://camel.465427.n5.nabb

FTP endpoint failure

Hi, I have a small camel route where my input endpoint is FTP. I want to handle the scenario when FTP is down or the FTP credentials are wrong. But I checked that FTP does not throw exception on the consumer side, instead it just keeps on retrying after every 5 seconds. Can you please tell me how

Re: Camel JMS retry mechanism

The exception listener does not work because the exception is not thrown. I checked the underlying classes in the jar. In the DefaultMessageListenerContainer.java, there is method refreshConnectionUntilSuccessful() which keeps on retrying to connect to JMS. It has a try-catch block where the connec

Re: Camel JMS retry mechanism

Can you please give me a sample code of the custom class that I need to implement for the exceptionListener? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-JMS-retry-mechanism-tp5734328p5734348.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel JMS retry mechanism

I dont acheive anything by putting the onException block because as I said, there is no exception thrown from JMS. Hence the control never goes to the onException block. The connection failure message is logged into a warning and it keeps on retrying again and again -- View this message in conte

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

Exception when using FTP as endpoint

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 location. This seda location is the input for the second route which again processes the file and sends it to the same FTP location. But when I run this rou

java.util.concurrent.RejectedExecutionException: null during route shutdown

Hi , I have a camel route which I am trying to shutdown in case I encounter a java.net.ConnectException. In my shutdown strategy, I am removing the keys that I had added in the context properties during the route execution and then shutting down the route as follows: exchange.getContext().stopRou

Re: CronSchedulePolicy with cxf endpoint

We are stopping the route dynamically using a shutdown processor based on some business conditions. Basically, shutdown processor has the below code: exchange.getContext().stopRoute(RouteID,6,TimeUnit.MILLISECONDS); This results in the following log statement on the console: "Graceful shutdo

Re: CronSchedulePolicy with cxf endpoint

My route looks like this: CronScheduledRoutePolicy cronScheduledRoutePolicy=new CronScheduledRoutePolicy(); cronScheduledRoutePolicy.setRouteStartTime("0 0/3 * * * ?"); from("some sftp location") .noAutoStartup() .routePolicy(cronScheduledRoutePolicy) .to("cxf location") -- View this message i

CronSchedulePolicy with cxf endpoint

Hi, I have a cron expression which triggers the route at a particular time everyday. This works fine with all the endpoints like ftp,sftp, etc. But when I use a cxf endpoint, the route runs for the first time, but the next day the route does not start. Can you please tell me why this is happening?

Re: Endpoint configuration error

Thank you for your reply claus. I am using camel 2.10.2. It's a normal java function. The function returns the JmsEndpoint which I later use in my route. But even though I put try catch block, I get this exception thrown out. Apparently the code does not go to the catch block. Currently my catch b

SFTP authentication issue

Hi, I am trying to connect to an SFTP endpoint. The JSCH class uses the following parameters for authentication: ("PreferredAuthentications", "gssapi-with-mic,publickey,keyboard-interactive,password") If I use the custom JSCH class then I am not able to connect to my SFTP endpoint because of the g

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: Exception in restful web service

I tried to make the function return a simple string : @GET @Path("/xmlHello") @Produces ( "application/xml" ) public String getHello() { return "Hello"; } Also i removed the cxf.xml but still I am getting the same exception. Please help me with this issue. -- View this message in context:

Re: Exception in restful web service

My server class looks like this: import java.io.BufferedReader; import java.io.DataInputStream; import java.io.FileInputStream; import java.io.InputStreamReader; import javax.ws.rs.Consumes; import javax.ws.rs.GET; import javax.ws.rs.Path; import javax.ws.rs.Produces; @Path("/hello") public cl

Re: Exception in restful web service

Thank you for the reply Willem. Yes, I can access the rest service with simple get request. If I type the url for accessing the function in the browser, I get the output on the browser window. But in this case, my function is accessed ( I have a sysout in the function which tells me that the functi

Exception in restful web service

Hi, I have a restful webservice that I am invoking using camel-cxf. I want to call a particular function on the server. I can call the server but I am getting the following exception while processing: org.apache.cxf.jaxrs.client.ClientWebApplicationException: .No message body reader has been foun

Re: RestFul service using camel

Thank you Claus. I get your point. I want to invoke a rest service hosted in a remote server and hence should be putting the rest url in as a to endpoint. But i am unable to get through the format of the url to be passed as a TO endpoint. Firstly i am using cxfrs component to invoke the rest servi