Assistance Required on Exception Handling in Camel Kafka Consumer/Producer Routes

nce for your time and support. We look forward to your guidance on this matter. Regards, [ION] Vineet Kumar vineet.ku...@iongroup.com<mailto:vineet.ku...@iongroup.com> m +91 9003801369 iongroup.com<https://www.iongroup.com/> [Impact]<https://www.linkedin.com/showcase/ioncommodities/posts/?feedView=all>

Shutdown of camel routes

Hi I am using camel (3.14) with springboot. Application is also using camel quickfixj to connect with the vendor platform via FIX protocol. Application has a public camel route that consumes messages from the Fix session, but when I shutdown the application, the public route stops first and the q

Re: Questions regarding Graceful shutdown

if you do then it comes with its own shutdown strategy. > > > On Tue, Jan 10, 2023 at 11:42 AM Gaurav Kumar > wrote: > > > Thanks for your response. > > > > I have tried setting up in context > > context.setShutdownStrategy(new DefaultShutdownStrategy()); >

Re: Questions regarding Graceful shutdown

Received hangup signal, stopping the main instance.* On Tue, 10 Jan 2023 at 13:53, Claus Ibsen wrote: > How do you run Camel? Spring Boot or some other way. > > Also you should 99% not implement your own shutdown strategy but just > configure the out of the box. > > On Tue, Jan

Questions regarding Graceful shutdown

Hi Team I am using camel version 3.14.4 and trying to implement clean shutdown. As per the link below https://camel.apache.org/manual/graceful-shutdown.html , I can implement Graceful shutdown by implementing DefaultShutdownStrategy. I have added it in configuration and can see that bean has been

single camel kafka jdbc sink connector for 100 topics

Hi Team, We have a requirement to sync table records between 2 database . We use strimzi kafka and debezium source connector for CDC. Now we have records from 100 tables into 100 topics in kafka which need to be inserted into target database. I was trying to use camel sql server/Jdbc sink conne

Support for UniVocityFixedWidthDataFormat in Camel 3.15.0

which we are facing issues in our codebase. Could you please share any documentation or release notes where we could find the work around for the same? Any help would be appreciated. Thanks and regards, Vipul Kumar

Kafka reset during vm restart

Hi Team , During our vm patching activity , once vm is restarted and we bring up our camel springboot jar . We have noticed that Kafka consumer starts consuming message from beginning causing lot of duplicates. In server log we found below error message. Camel version = 3.8 Fetch offset 18036 i

Re: Quartz: Set trigger misfire instruction

Any help please. Thanks, Shiva On Tue, 29 Jun 2021, 4:18 p.m. shiva kumar g.v, wrote: > Hi Claus, > > Camel version=3.8.0 > > Issue faced: when ever i restart my springboot jar i get below message in > log and Quartz scheduler immidiately trigger job. > > I want to

Re: Quartz: Set trigger misfire instruction

ks, Shiva On Tue, 29 Jun 2021, 4:03 p.m. Claus Ibsen, wrote: > Hi > > Can you provide more details. What Camel version. And post at least > all the route code where you use that quartz thingy. > And paste the exception / error message. > > On Mon, Jun 28, 2021 at 7:07 PM sh

Quartz: Set trigger misfire instruction

Hi team, How can we set trigger misfire instruction when using QuartzScheduledPollConsumerScheduler. ? I tried setting scheduler.trigger.misfireInstruction=2 .it threw error. Invalid parameter. Thanks, Shiva

Quartz: Set trigger misfire instruction

Hi team, How can we set trigger misfire instruction when using QuartzScheduledPollConsumerScheduler. ? I tried setting scheduler.trigger.misfireInstruction=2 .it threw error. Invalid parameter. Thanks, Shiva

Re: ConcurrentModificationException while calling REST service using camel-cxf component

HI Team Please update on issue. This issue is intermittent. We are not able to replicate this issue at our end. Thanks & Regards Anand Kumar On Thu, Apr 8, 2021 at 9:00 PM Anand Kumar wrote: > HI Claus > > We are using 2.23.2 version for camel and cxf > > Regards > Anand

Re: ConcurrentModificationException while calling REST service using camel-cxf component

HI Claus We are using 2.23.2 version for camel and cxf Regards Anand Kumar On Thu, Apr 8, 2021 at 5:38 PM Claus Ibsen wrote: > What Camel and CXF version are you using? > > On Thu, Apr 8, 2021 at 11:53 AM Anand Kumar > wrote: > > > > Hi Team > > > >

ConcurrentModificationException while calling REST service using camel-cxf component

org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean.createWebClient(JAXRSClientFactoryBean.java:225) ... 43 more -- Thanks and Regards, Anand Kumar, +91-8452844232

camel-sql | sql-stored component queryTimeout option not present

Hi Team How to setQueryTimeout while calling stored procedure using sql-stored component ? Please help. Regards Anand Kumar

Re: camel sql-stored component queryTimeout option not present

Hi Claus Thanks for replying. I have raised JIRA : CAMEL-16405 Thanks and Regards Anand Kumar On Thu, Mar 25, 2021, 20:10 Claus Ibsen wrote: > Hi > > This is not possible, this requires to implement an improvement to the > camel-sql component. > You are welcome to create a

camel sql-stored component queryTimeout option not present

Hi Team How to setQueryTimeout while calling stored procedure using sql-stored component ? Please help. Regards Anand Kumar

Using Server-Side-Events (SSE) with Camel acting as a reverse-proxy

I want to be able to use Server-Side-Events (SSE) in a web service to send a stream of messages to the browser and I have a Camel application acting as a reverse-proxy between them. However the Camel route is buffering the messages sent using SSE and messages are not delivered to the browser un

Apache camel running on multiple nodes

Hi Team, I want to run the apache camel file route on multiple nodes and the source folder is the same for both nodes and expecting the route to process files parallelly > when I tried the running camel on multiple nodes, files are processing in a round-robin fashion (only one ode processing is

Help required for Camel components deployed in cloud

Hi , We required help for camel components deployed in AWS cloud. Please share any cloud formation template is available. Thanks SenthilKumar SK

simple language bodyOneLine throws error

Hi team, I am trying to use camel simple expression bodyOneLine for logging payload in single line. But it throws below error while starting the route. Camel version= 2.23.1 Code: .log(org.apache.camel.LoggingLevel.INFO,"Request Received : ${bodyOneLine}") Error: Caused by: org.apa

camel-rabbitmq component issue

I am implementing the quorum queue feature of rabbitmq. Following is the route configuration for the implementation:- context.addRoutes(new RouteBuilder() { public void configure() throws Exception { from("timer:hello?period=1000") .transfo

IBM MQ with camel

Hi All, I was trying to read message from IBM MQ queue with the help of the code mentioned in below thread https://camel.465427.n5.nabble.com/Can-Camel-communicate-over-IBM-MQ-sender-receiver-channels-td4429050.html I am able to connect to IBM queue, but whenever am trying to print the content

Tracing camel-zipkin-starter with Rabbitmq

m.xml and application.yaml for reference. Do let me know in case more information is required Regards Prabhat Kumar %d{-MM-dd'T'HH:mm:ss.SXXX}|2|%level|example-service|%X{X-B3-TraceId},%X{X-B3-SpanId},%X{X-Span-Export}|${sys:PID}|%thread|%lo

Scheduled batch job using apache camel

Hi, Is there any good reference material for creating scheduled spring batch job using Apache Camel? Regards, Sanjeev

Re: Workflow UI Editor

an > > On Thu, Feb 21, 2019 at 1:57 PM Sanjeev Kumar wrote: > > > > Hi, > > > > Looking for an open source UI editor which can be used by business to > > modify or create new workflows and generate Spring XML DSL from that. > > > > Have anyone use

Workflow UI Editor

Hi, Looking for an open source UI editor which can be used by business to modify or create new workflows and generate Spring XML DSL from that. Have anyone used similar thing in their project? Any pointers will be helpful. Regards, Sanjeev

Transaction state storage with LRA

Hi, I read all documents and failed to understand where LRA stores the transaction state? What will happen if LRA will be down for some reason while some transaction is in progress? Any pointers or inputs will be helpful. Regards, Sanjeev

Camel + Spring DSL + LRA SagaService

Hi, Thanks for guiding me how to add InMemorySaga service. It worked like Charm!! Now, I am trying to work with LRA Service and as mentioned at https://github.com/apache/camel/blob/master/camel-core/src/main/docs/eips/saga-eip.adoc, I added LRA and Undertow dependencies. But, when I am starting t

Camel + Spring DSL + InMemorySagaService

Hi, I would like to understand how to add Camel's InMemorySagaService using Spring DSL as mentioned in JAVA DSL at https://github.com/apache/camel/blob/d5ba98ed43229afe1c1aa24e8e3d6492460d8bd4/camel-core/src/test/java/org/apache/camel/processor/SagaTest.java#L100-L101 Thanks & Regards, Sanjeev

Re: Camel Examples seem outdated/buggy

; > Le 12 mai 2018 12:54 PM, Mohit Kumar a écrit : > > > > Hi All, > > > > I am a newbie in Camel and trying out the sample provided at > https://github.com/apache/camel/tree/master/examples/ > camel-example-jms-file <https://github.com/apache/ > camel/t

Camel Examples seem outdated/buggy

Hi All, I am a newbie in Camel and trying out the sample provided at https://github.com/apache/camel/tree/master/examples/camel-example-jms-file I am facing compilation issues while building this project: [INFO]

Camel-salesforce Intermittent time outs

Hi, We are using the sales force component and trying to write to external salesforce health cloud using the camel salesforce component. Most of the times, the data seem to flow. However abruptly I see the below errors. If I reprocess the failed one again, it would work. But looks like this ke

Camel with SSL and HostNameVerifier

Hi All, I'm new to camel. Plese suggest me how Ican change this class into camel route xml. Plese give me suggestions import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.Unsupp

Re: Camel with Karaf + Blueprint

My Blueprint XML files has beans defined and Camel Context defined in it. remaining are routes files. with camel namespace Best Regards Kumar Phani: Touchpeak Software cell: +65 9821 8689 email: ku...@touchpeak.com On Tue, Mar 21, 2017 at 10:18 PM, Quinn Stevenson [via Camel] < ml-n

Karaf +Camel Blueprint not able to load bean from other active bundles.

Hi , We are using Blueprint + Camel + Karaf ,migrating from Spring . I am new to OSgi Blueprint . We are using Blueprint XML to define services from beans defined in blueprint xml. After we added Service in Blueprint XML, atleast are getting from karaf as below: fyi: bundle is in Active state

Re: Camel with Karaf + Blueprint

I found the isssue now I am able to load routes and beans . but beans I think i have t make as service to regsiter with Camel and access from other route xml files. Strange thing here is I thin k it is bug in Camel- even though I am using blueprint XML dsl it looks for Spring in . *Problem:* h

Re: Camel with Karaf + Blueprint

Hi , I am getting below issues with loading Camel-Routes.xml (which has with blueprint namespace). javax.xml.bind.UnmarshalException: unexpected element (uri:"http://camel.apache.org/schema/blueprint"; local:"routes"). Expected elements are <{http://camel.apache.org/schema/spring}aggregate> <{

Re: Camel with Karaf + Blueprint

0 down vote favorite I am trying to use Camel(2.18.2) + karaf(4.0.8)+blueprint(Aries) for my migration as suggested by experts. I have separated files as Routes XML files and Beans XML files. RouteXml-> it has only Camel Routes BeanXml-> it has only beans defines *Structure::* *

Camel with Karaf + Blueprint

s in Karaf Container. Please help me on how to load beans from other bundles. I did export all packges from other bundles. Thanks, Kumar -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-Karaf-Blueprint-tp5795036.html Sent from the Camel - Users mailing list

Re: Camel with OSGI in Felix with Spring DSL

Now I started Looking into blueprint-Aries + camel , migrating all codes and xml namespaces from spring. Lets see how ot would be.. Thanks for all your support. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-OSGI-in-Felix-with-Spring-DSL-tp5794738p5794984.html S

Re: Camel with OSGI in Felix with Spring DSL

Hi Tim, Thanks for your suggestion. After going through some forums , I found that Gemini Blueprint which supports Spring + Camel in OSGi world. Whats your opinion on GEMINI BLUEPRINT ? is it worth to try with gemini ? Thanks, Kumar -- View this message in context: http://camel.465427.n5

Re: Camel with OSGI in Felix with Spring DSL

Hi , Please some helping hand needed. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-OSGI-in-Felix-with-Spring-DSL-tp5794738p5794813.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel with OSGI in Felix with Spring DSL

Hi Grzegorz Grzybek , I tried your way , installed karaf 4.0.8. Unable to load spring-dm getting below error: *karaf@root()>* feature:install camel-spring-dm Error executing command: Error karaf@root()> No luck. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-O

Re: Camel with OSGI in Felix with Spring DSL

Hi Claus, I tried using karaf after your suggestion. I executed below commands on karaf Shell: I am using karaf:4.1.0 NO Luck not able to start the feature you provided for Camel-spring. details are given below. *karaf@root()>* feature:repo-add camel 2.18.2 Adding feature url mvn:org.apache

Re: Camel with OSGI in Felix with Spring DSL

Hi Claus, Thanks for quick reply . Surely I will look into karaf and try out samples in github . Even I prefer karaf and amazed with functionalities it provide as a container. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-OSGI-in-Felix-with-Spring-DSL-tp5794

Camel with OSGI in Felix with Spring DSL

right direction , if it works for me I will put some efforts to have a simple demo example for beginners like me. Thanks, Kumar -- View this message in context: http://camel.465427.n5.nabble.com/Camel-with-OSGI-in-Felix-with-Spring-DSL-tp5794738.html Sent from the Camel - Users ma

Re: camel quartz2 scheduler external quartz.properties file

Hi Claus, I tried by making a QuartzComponent using java config. But this one is not getting detected in my camel-quartz component. @Bean //@Produce(uri="quartz2://myscheduler2?cron=0+0/2+0+?+*+MON-SAT") public QuartzComponent quartzComponent(){ System.out.

camel quartz2 scheduler external quartz.properties file

We have a spring boot backed camel project and we are using a camel-quartz2 component . The problem is by default the quartz.properties file is expected to be present in org.quartz directory inside the src/main/resources directory . Is there any possible way where i can give the location of the qua

Re: Camel:Mina2 for multiple exchanges on same connection with producer template

I was able to do it using small compknent changes in MINA2 and stop creating new exchanges evrytime for new messages to allow mulitple messages on same exchange. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Mina2-for-multiple-exchanges-on-same-connection-with-produc

Camel:Mina2 for multiple exchanges on same connection with producer template

Hi , I have a issue with Camel:Mina2 for doing multiple exchanges with client . TCpClient1--> Camel:mina2--> Xprocessor XProcessor-->ProducerTemplate<-Inout->TcpClient1 XProcessor-->ProducerTemplate<-Inout->TcpClient1 Xprocesssor expects Producer template response from TcpClient1 I mean first

Re: use camel to send mail with word table

Hi Claus, Converting the data set part is clear for me. Where i am stuck is what should be the camel mail config parameters and the content type so that the data goes into the body of the mail, not as an attachment. Regards, Deepak -- View this message in context: http://camel.465427.n5.nabble

use camel to send mail with word table

we have a data set in terms of json array. we want to send the json contents as word table data using apache camel. Can anyone please suggest how to achieve that? the data set looks like:- {"id":12,"name":"abc","age":25} {"id":13,"name":"xyz","age":26} {"id":12,"name":"mno","age":26}

Multiple schedulers in apache camel

I have two schedulers in my route and i want each schedule to fire at some particular time of a day and each scheduler is meant for a different task process.But when i write the below configuration i doesn't execute properly. I don't understand why both the schedulers are running like this ,not acc

Re: How to disable errorHandle in subroutes in Spring DSL

Hi Claus, I dont have sub element under route with errorHandler. So I still not getting how to configure that. But i have taken other approach with try.catch. with handled as false. java.lang.Exception false Now it propogates. Thanks for help guys. -- View this message in context: http:

How to disable errorHandle in subroutes in Spring DSL

Hi All, I have been looking for , how to disable errorhandle in subroute in order to catch exception in Parent route. I have seen couple of examples in java dsl but not in spring dsl ? Thanks, Kumar -- View this message in context: http://camel.465427.n5.nabble.com/How-to-disable

Re: camel consume message from multiple jms endpoint based on condition

Hi Claus, We are using solace as the jms component and its a queue. Basically it is a spring boot camel project . So during application startup from the properties file it creates the jms component. application.properties:- jms.connectionType=solace jms.solace.solaceJmsVpnContext=Solace_JMS_VPN

camel consume message from multiple jms endpoint based on condition

i have a camel route which polls a jms component and this works fine for me. But we have another requirement here there should be 2 jms endpoints .if first endpoint is not up then camel should polls the 2nd endpoint.Can anyone suggest how to achieve this? thanks in advance.. -- View this messag

Not able to create an multiple rest consumers

create two rest consumers in one single camel context. Thanks, Kumar -- View this message in context: http://camel.465427.n5.nabble.com/Not-able-to-create-an-multiple-rest-consumers-tp5785416.html Sent from the Camel - Users mailing list archive at Nabble.com.

Sample Projects in Camel

Hello all, I was thinking to have sample projects in camel. Something in the same as find in spring boot. Not sure how to start, can anyone guide. Currently I'm free so I thought I could learn Camel and would help community too. Regards, Bharath. http://www.m

Re: Rest DSL - how to configure SSL/Basic Auth for jetty component?

I am using Swagger and rest dsl to build an application. Need to implement Basic Auth. how can i implement SSL/ Basic Auth for jetty component in blueprint xml? .endpointProperty("sslKeystore", "/security/serverKey.jks") how i can configure in blueprint.xml file. -- View this message in context:

camel not supporting utf-8 character

I have a spring boot camel project. Then there is a route which fetches xml data from activemq. When i run the program through STS -> Run as Spring Boot app it works fine for UTF-8 char encoding. But when i make the fat jar and run it then in the logs i get junk characters for chinese fonts. My log

Re: mock http endpoint and retrieving value form properties file

Hi Quinn, My test class looks like this. When i am trying to run i am getting error message like- No bean "testProcessor" found in the registry. public class FirstTest extends CamelSpringTestSupport{ @Override protected AbstractApplicationContext createApplicationContext() {

Re: mock http endpoint and retrieving value form properties file

Hi Quinn , I got it how to get the value from properties file. But how can i test the http endpoint here.and that to based on different http response status? if the status will return 404 then i will throw custom exception. how can i test these scenarios? -- View this message in context: http:/

mock http endpoint and retrieving value form properties file

I have route in my camel context like this:- routename How can i test the abo

Getting restHostNameResolver error while trying to integrate swagger with ApacheCamel

Hi, I have an existing project where i need to integrate the swagger by use of annotations. When i do jetty:run i get error when i am trying to read the swagger.json. Would someone be able to provide me some direction on this. Below is the stack trace. java.lang.IllegalArgumentException: Conflict

How to log the messages for enrich

HI , I have route with enrich to communicate with host in soap message format. but how can i log the outgoing / incoming messages of soap using spring dsl. Thanks, Kumar -- View this message in context: http://camel.465427.n5.nabble.com/How-to-log-the-messages-for-enrich-tp5772970.html Sent

Re: Query

t-list.html > > > > > > > > On Thu, Oct 8, 2015 at 1:38 PM, ram kumar > wrote: > >> Hi, > >> i would like to set the hdfs path to the current time (in millisecond), > >> but CamelContext takes from conf once, is it possible to change it >

Query

Hi, i would like to set the hdfs path to the current time (in millisecond), but CamelContext takes from conf once, is it possible to change it .to("hdfs://"+ System.currentTimeMillis() + "/") Thanks

Weird exceptions with tomcat camel

Hi, Added below in pom.xml org.apache.camel camel-core 2.14.1 org.apache.camel camel-servlet 2.14.1 org.apache.camel camel-hdfs 2.14.1

Recipient List

hi, i am new to camel. can anyone suggest how recipient list works on aws-s3 consumer

s3 query

Hi, my use case is a dynamic consumer where , .setHeader(S3Constants.KEY, simple("query" + System.nanoTime())) -> this should change according to time .to("aws-s3://camel-qq?accessKey=&secretKey="); can anyone help me Thanks

query file to s3

Hi, This will write the file present in directory sample to checkoutputdir1 from("file:///home/ram/sample/") .to("file:///home/ram/checkoutputdir1/"); My use case is to push to s3 from("file:///home/ram/sample/") .setHeader(S3Constants.KEY, simple("check5")) .to("aws-s3://camel-qq?accessKey=&secr

Query on camel s3

Hi, I have a producer which points to a directory I want to consume to s3, inside a particular directory Can anyone help me with that .from(file:directoryName) .setHeader(S3Constants.KEY, simple("check1")) .to("aws-s3://camel?accessKey=&secretKey=®ion=&"); Thanks

Re: Request body is empty in HTTP Endpoint

Ok. Found out the issue. AM sending plain text data, but my rest service is parsing it as JSON and was showing empty JSON So just make sure these two 1. In camel, add Content-Type *.setHeader(Exchange.CONTENT_TYPE,constant("text/html")) * 2. In your Rest service

Request body is empty in HTTP Endpoint

Am forwarding queue data to a REST Url which is running in a remote location When I do, the request body is empty. *{}* This is the route spec from("test-jms:queue:test.queue") .setHeader(Exchange.HTTP_METHOD,constant("POST")) .setHeader(Exchange.CONTENT_TYPE,co

Re: Camel Websocket - Connection key not set

Hey Thanks for the suggestion Now am using AH-WS component. Leaving the websocket code untounced, now I get this error java.lang.NullPointerException at org.apache.camel.component.ahc.ws.WsProducer.sendMessage(WsProducer.j ava:77) at org.apache.camel.component.ahc.ws.WsProducer.pr

Camel Websocket - Connection key not set

I have the below route in Camel from JMS --> Websocket The websocket is exposed in a node js appliation running separately. and this is my route specification /from("test-jms:queue:test.queue").convertBodyTo(String.class, "UTF-8").to("websocket://localhost");/ When I run the code, i get the fo

Camel multicast and exception

.eventDesc}'), utl_raw.cast_to_raw('${body}')) ${property.eventid}:${property.eventdesc} ---- Thanks, Kishore Kumar Desu.

Apache Camel access a Spring Bean which invokes a Stored Procedure , Below is a Screenshot of SpringXML-Config file that hits a Stored Procedure successfully and display results.What would be the best

-- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-access-a-Spring-Bean-which-invokes-a-Stored-Procedure-Below-is-a-Screenshot-of-SpringXMl-tp5761959.html Sent from the Camel - Users mailing list archive

camel 2.14.1 rest component - read headers

As per the documentation, we can read headers using ${in.header.headerName}, which is returning empty. Please help me to read header values in my case. Thanks, Kishore Kumar Desu.

Unable to insert data using camel hibernate component.

ards T.V.Santhosh kumar 095382 55159

Migrating from Fuse ESB to Fuse Service Works

I wrote a camel file transformation component on camel springs. I deployed it on Fuse ESB 6.0 and it ran successfully. Now, I need to deploy the same component to Fuse Service Works (JBoss 7.1). I am not sure how to bundle it, or what all changes will go in pom.xml. Please help with the steps that

Running camel Route in multiple threads

Hi, I want to run my camel route in multiple threads. Is there any way i can run same route in multiple threads. basically same route execute parallely in multiple threads. Thanks, Tarun

Re: camel jms polling

Thanks. That works! On Thu, Jan 9, 2014 at 1:28 AM, Christian Posta wrote: > give your timer name something unique for each route: > > http://camel.apache.org/timer.html > > On Wed, Jan 8, 2014 at 9:11 AM, Tarun Kumar > wrote: > > Here problem is both routes are runni

Re: camel jms polling

Here problem is both routes are running sequentially. I tried with as well, doesn't help. On Wed, Jan 8, 2014 at 10:08 PM, Tarun Kumar wrote: > Hi, > > I have two routes > > > > > > > > > > > > > > > > > > >

camel jms polling

Hi, I have two routes in bean1 and bean2, i poll messages from different JMS queues. When i start the server, polling consumer in bean1 waits (and blocks) for messages to be available in jms queue. Is there any way i can run both routes in parallel?

Re: polling consumer with acknowledgement

) and Maintainable Java (2012)* > *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39 > <http://www.linkedin.com/pub/robert-simmons/40/852/a39>* > > > On Mon, Dec 23, 2013 at 2:11 AM, Tarun Kumar >wrote: > > >

Re: polling consumer with acknowledgement

siness. If you want a > composite transaction that rolls back both the DB and JMS work then you > will need to configure a jta transaction manager. Just google 'camel > jta transacted route' and you will get code examples and so on. > > On Saturday, December 21, 2013, Tarun

Re: polling consumer with acknowledgement

down another path. > > On Saturday, December 21, 2013, Tarun Kumar wrote: > > > Hi, > > > > Any help here will be highly appreciated. > > > > > > On Fri, Dec 20, 2013 at 9:55 AM, Tarun Kumar > > >wrote: > > > > > I am using pol

Re: polling consumer with acknowledgement

Hi, Any help here will be highly appreciated. On Fri, Dec 20, 2013 at 9:55 AM, Tarun Kumar wrote: > I am using polling consumer. > > from("timer://foo?period=5000").bean(cool, "someBusinessLogic"); > > public static class MyCoolBean { > > private Cons

polling consumer with acknowledgement

I am using polling consumer. from("timer://foo?period=5000").bean(cool, "someBusinessLogic"); public static class MyCoolBean { private ConsumerTemplate consumer; public void setConsumer(ConsumerTemplate consumer) { this.consumer = consumer; } public void someBusinessLogic()

Re: Polling consumer in camel

s.html for details > (paragraph "Disabling auto-mapping of JMS messages"). > > > On Wed, Dec 18, 2013 at 7:59 PM, Tarun Kumar >wrote: > > > Hi, > > > > I am creating a polling consumer using: > > > > from("timer://foo?period=5000").bean

Polling consumer in camel

Hi, I am creating a polling consumer using: from("timer://foo?period=5000").bean(cool, "someBusinessLogic"); public static class MyCoolBean { private int count; private ConsumerTemplate consumer; private ProducerTemplate producer; public void setConsumer(ConsumerTemplate consum

Re: invoking camel route

t; > You can use a producer template to send a message to a Camel route > from java code. > > On Thu, Jul 18, 2013 at 5:58 PM, Tarun Kumar > wrote: > > Hi, > > > > I want to invoke camel route from java code. > > CamelContext doesn't seem to have a

invoking camel route

Hi, I want to invoke camel route from java code. CamelContext doesn't seem to have any method to invoke route. Here is what my code looks like: @Autowired private CamelContext cc; public void testMethod() { System.out.println(cc.getRouteStatus("route1")); // prints true // how to invoke

Re: Is onFinally() compulsory after doCatch()?

in between is > inside the doCatch. > > > > On Tue, Jul 2, 2013 at 12:36 PM, Tarun Kumar > wrote: > > Above link doesn't answer my second ques. Could you please help? > > > > > > On Tue, Jul 2, 2013 at 12:41 PM, Christian Müller < > > christ

Re: Is onFinally() compulsory after doCatch()?

com/pub/christian-mueller/11/551/642 > > > On Tue, Jul 2, 2013 at 7:50 AM, Tarun Kumar >wrote: > > > my route looks like this: > > > > from(). > > .toTry().process() > > .doCatch(Exception.class) > > .to().to().process() > > .end() > >

Is onFinally() compulsory after doCatch()?

my route looks like this: from(). .toTry().process() .doCatch(Exception.class) .to().to().process() .end() My questions are: 1. is .doFinally compulsory after doCatch()? 2. In my case, how does route know whether second .to() in line 4 is inside doCatch() or after doCatch()? 3. I am using cxfrs

  1   2   >