Polling consumer & retry based on content strategy I have this situation: 1 - I want to poll a jms/activemq queue every x minutes. 2 - Execute some business logic 3 - On success just log it 4 - On failure, send back to the queue for a retry of the route (1-... 
how to remove messages from deadletter queue after sucess elsewhere I currently have system A connected with system B where A sends an updated document every time it changes in it. The document is sent through a webservice provider deployed in the bus and serving as a route endpoint. ... 
Bundle with routes being inherited by another bundle Hopefully this will make sense. Its more of a architecture question since most of my camel route tests have suddenly started to fail and weird things have started to occur after I've just moved from "fuse-7-06... 
how can i access a web service with basic authentication hi, i have to access a web service that is using basic http authentication. here is my blueprint.xml: but how can i set the the username and password in the http hea... 
CamelSmppId order Hi, When using camel-smpp the destination addresses are set in a header called "CamelSmppDestAddr" - which is a List. Are the elements of CamelSmppId guaranteed to be in the same order as CamelSmppDest... 
Callback based on multiple wireTaps? Hi, I am trying to acheive something like the following: But the trouble with that is the end result is dependent on destination1 and destination2 completing not just destination2. ... How to load properties from external source ? Hello, I'd like to read properties e.g. complete groovy scripts from an external source for example a separate file or a database. As I understand the properties mechanism works with key : value pairs but thi... 
Warning can't determine annotations of missing type $Proxy89 I am trying to write create an aspect in my camel application with the following snippets: <ctx:component-scan base-package="com.interswitchng.techquest.paydirect.payment.notification.service.soap" /> &... 
Spring AOP, AspectJWeaver and Camel I am trying to implement some Aspect Oriented Programming on Camel with AspectJWeaver, but I kept getting : Caused by: java.lang.ClassNotFoundException: org.aspectj.weaver.reflect.ReflectionWorld$ReflectionWor... fuse ESB choking on camel routes... hi, i have components defined in osgi for activemq, processor, output1, output2... I have defined 20 camel routes similar to the following: .from("activemq:topic:topic1") .to("my... 
camel route writing to a file.... hi, Im trying to run a route to a file. Unfortunately, the default seems to be that the file processor overwrites the file each time a message comes in... so I added the "fileExist" parameter and now I am getting an e... building a camel route using java... hi, I am looking for example code. given this in DSL: from("uri").filter("...").processor("...."); there must be a way to do this: Obj x = from("uri"); x.filter("...");... camel-cdi and REST with cxf Hello, how can I setup a REST service using the camel-cdi component ? For cxf I think it is required to add parts from application context somehow in the bootstrap class of the camel cd... Spring Dependency Injection and AOP (annotation): are they allowed in camel Hi, Can use Spring's Dependency Injection and Aspect Oriented Programming concepts in Camel context. I want to inject objects and monitor with aspects in camel, is this possible? If yes, how can this be achi... aggregation failed Hi All i have to aggregate two XML files which are converted from csv format successfuly ,available at different times. I have to aggregate both xml file to single xml file. But I am fac... 
Unit testing a route with a from activemq I am trying to unit test a route - i am using blueprints - which uses active mq (see below) I then have this in my java code: protected CamelContext createCamelContext() throws Exception ... address from a cxf-web-service received a request Hello! Can anyone tell me how to find the address where cxf-web-service received the request. service settings: //beans.xml //route ... 
need to get the BundleContext instance in my soap webservice class Hi All, I have created soap webservice(using cxf - jaxws), auhenticatewebsevice(bundled as jar) I need to invoke the getUsers method of some other bundle ex: security(which is war bundle).. I have some of the class... 
How to setThreadName() for .threads() in routeBuilder? hi, I have as part of my route from("...") .threads(poolSize, maxPoolSize) .beanRef(...); How I can name my thread pool? The ThreadsDefinition.setThreadName() is void and threads() doesn't have an... 
Why File Pooler doesn't creates new threads? Hi, I have: from("file:" + importDir + importOpts) .beanRef("aBean"); the directory has above 100 files, however I don't see any more threads from this File Producer. As importOpts I have "/?n...
Log in to follow, share, and participate in this community.