jms and transactional fetching

Hi I've encountered a scenerio I'm unable to implement using Apache Camel. I want to have a component that polls messages from JMS queue and processes them in some way. The problem is, there may be some problems, errors, exceptions, and the processing fails. That's why I need to leave the messa

Re: [ camel ] Help required for simple transactional Route for forwarding messages from ActiveMQ to TCP port

On 02/16/2011 01:58 PM, Tom Howe wrote: > Hi, I'm new to Camel and I am trying to create a simple app that consumes > messages from an ActiveMQ queue and forwards them to a TCP port (splunk). If > the TCP connection is down I want the message left on the queue and retried > with expontential backof

Multiple durable consumers on jms topic

Hi I'm having some weird behavior with JMS one-producer-multiple-consumer situation. I'm publishing messages to jms topic and than have multiple consumers which poll messages from it. Each consumer is in separate SU and I'm deploying all the components in SMX (3.3). The problem I'm observing i

Re: Multiple durable consumers on jms topic

Replying to myself. Seems like the problem does not exist if I use external Activemq broker. Nevertheless it would be nice to have it working with the embedded one. Regards Marcin -- View this message in context: http://old.nabble.com/Multiple-durable-consumers-on-jms-topic-tp27930623p2794260

cxf bean exposed via camel

Hi I'm trying to expose cxf service bean via cxf-camel transport. Basically I want my bean to be accessible via JBI in Servicemix 4 - some other services refer this service by jbi endpoints. Theses services are also camel routers. Unfortunatelly the whole setup fails, the cxf bean never rece

Re: [ camel ] XML Namespace and Xpath injection

On 09/12/2011 02:21 PM, atouret.nos...@free.fr wrote: Hello, I'm trying to inject a value in bean trough an xpath injection as following : public void audit(@XPath("/Envelope/Body/getToken/username/text()") String id, @Body String body) { logger.info("Id :"+id );