Calling {body.getXXXXXX}from Simple EL taking > 200 ms

Hi I notice that when making method calls on the body using the Simple EL they are quite slow depending on the size of the object on the exchange, e.g. ${body.getXX} Is there anyway to speed this up? Thanks Joe -- View this message in context: http://camel.465427.n5.nabble.com/Calling-b

Re: Apache Camel EIP to process batch of messages identifying those which can be filtered

Thanks for the quick feedback. If I use the Idempotent Consumer EIP this would mean that the 2nd order (Order cancel) will be filtered out. However, I would want the new order to be filtered also. However, that would be sent to the counterparty with the Idempotent Consumer EIP Regards Joe --

Apache Camel EIP to process batch of messages identifying those which can be filtered

Hi My route calls a DB procedure which returns a large number of order objects. Before I send out the orders to a counterparty I want to examine the list of orders and see if the same order ID appears as both a new order and a cancel order, e.g. order 1001 returned as a new order and order 1001

Re: Query relating to the Rest Component

Thanks for the response Matt My camel based application is going to be deployed in to an existing apache tomcat container. Hence, I am thinking it probably makes more sense just to use the camel-servlet component and leverage its rest dsl support. However, would there be any any advantage of usin

Query relating to the Rest Component

Hi Want to expose a new Rest Service. Looking at using: (1) Apache Restlet component or (2) Apache Rest component Obviously the restlet component leverages the restlet implementation to implement a rest API. Unclear what rest framework/implementation that the rest component is using Thanks Joe

Exposing rest service from camel application using existing http transport

Hi I am looking at using the Rest component to define a Rest endpoint. My camel application gets packaged as a WAR file which I deploy in to my standalone tomcat instance. I am not sure if I can bind this Rest endpoint to HTTP requests that arrive at the HTTP endpoint on my tomcat instance. In

BAM support across different application running in different CamelContext's

Hi I have a use case where I need to track an order from a front office system to middle and back office systems. The camel BAM module looks like a good fit. But unless I am mistaken it appears to assume that all the routes run within the same CamelContext. Does it support having the different r

Outputting time to logs for route to process a message

Hi My route does some business processing - i.e. consumes messages from a topic, performs some business logic then sends message to a REST endpoint. After sending the message to the REST endpoint I have 1 final log statement to state the route is complete for this particular message. I would like

Idempotent consumer query

Hi I have a use case were I want to process the same message on my route up to a maximum of 5 times. I understand the idempotent consumer can be used to ensure we don't process the same messages twice. Just wondering if there exists already something similar to the idempotent consumer were you can

Re: Getting JMSConsumer to look for messages every N seconds

Thanks for the feedback. So just to confirm if I have the following route and I want to consume a message every 30 seconds would I inject in to the route a RoutePolicy(e.g. SimpleScheduledRoutePolicy) where I specify the routeStartRepeatInterval(30 seconds). I feel like I am missing something. What

Getting JMSConsumer to look for messages every N seconds

Hi I have a use case where I want to take messages from a DLQ and place them back on to main/primary queue which feeds the application. I want to move the messages every 10 seconds. I have looked at the delayer EIP but I would prefer take them from the DLQ every 10 seconds rather than taking them

Camel Delayer EIP query

Hi If I have the following route: from("activemq:b").delay(1).to("mock:result"); I understand that the message will be delayed 10 seconds before being delivered to mock:result. However, trying to understand does the message get taken from the queue and stored in memory until the 10 seconds

Aggregator query

Hi I have a use case were I need to log details about aggregated messages that are sitting in the aggregator for more than 60 mins without satisfying completion criteria. I have checked the documentation and don't see any obvious way of doing this. Any suggestions much appreciated Thanks Joe

Apache zookeeper component query

Hi My application needs to run hot/warm, i.e. 2 instances of the application running but routes running on one machine only. I am using the camel zookeeper component to solve this problem All works fine, when both instances of the application are starting up the 2nd instance outputs a big error m

Handling duplicate messages with aggreator

Hi I have the following use case. I receive in Order objects which all have an OrderId, ProductionId and ProductionCount. Hence, the productionId is my correlationExpression and the ProductionCount is the completionSize. This all works well. However, I may receive the same order twice(same Orde

Aggregator completionPredicate criteria question

Hi I am designing a system were the use of the aggregator is a good fit. First of all I need to use one of the Persistent AggregationRepository's. My concern with the approach is that I have certain edge cases were I may not receive all members of the group, e.g. I am grouping messages with a co

Conditional based routing query

Hi I have a route which consumes messages from a JMS Queue. The type of messages being placed on the queue are JMSObjectMessage's. There are 2 different types of objects I may be sent - a Customer or a Supplier. In the route which consumes the message I would like to do some conditional based rou

Enabling JMX on specific port when running junit test with CamelTestSupport

Hi My Junit test class extends: CamelTestSupport. I have overridden method *useJmx()* in my Junit test class to return true. When my junit test is running I can start up a JConsole session and examine routes etc. However, the JMX port on JConsole is different everytime I try to connect. I have

Re: Calling NTLM protected service from camel cxf component

Hi Surgey Thanks for the response. I am running on a tomcat instance on a linux server. The user is a windows user which is setup on our Windows Domain controller. I did try updating the (within the ) element to include an AuthorizationType: DomainName\${tod.user.userna

Calling NTLM protected service from camel cxf component

Hi I am having trouble calling an NTLM protected service from my route. When my route sends data to endpoint rsClient below it looks as if the conduit config is not applied. I see the following in the logs: 20150401 10:21:18,929 EDT DEBUG http.HTTPConduit [Camel (camel) thread #0 - JmsConsumer[O

Re: Using client_acknowledgement mode in route query

I am using camel spring DSL. Hence, not sure how I acknowledge the message myself -- View this message in context: http://camel.465427.n5.nabble.com/Using-client-acknowledgement-mode-in-route-query-tp5760618p5763863.html Sent from the Camel - Users mailing list archive at Nabble.com.

Question regarding subscribing to route notifications via JConsole

Hi I have a Java application that uses camel. When the application is running I can hook JConsole up to the application and enable the tracer property on the camelcontext. When tracer property is set to "true" I can subscribe to notifications on the tracer and they appear for me. Under the route

Issue setting property on the object which in the exchange body

Hi In my route, I have a header property on the exchange called age. In the body of the exchange I have a person object. I want to set the age property on the person object. If I do something like the following in my route and have the setAge property on the Person bean use the header annotation

Using CXF endpoint to call an NTLM protected Rest service

Hi Its not clear to me from reading the camel cxf endpoint documentation whether I can call an NTLM protected Rest service using the CXF endpoint. Any help greatly appreciated Thanks Joe -- View this message in context: http://camel.465427.n5.nabble.com/Using-CXF-endpoint-to-call-an-NTLM-prot

Using client_acknowledgement mode in route query

Hi I have a route which consumes a message of a queue, transforms it and and sends the transformed message to a REST endpoint. The JMS consumer is configured to use client_acknowledge mode. Hence, the message will not get de-queued until I get a successful response from the REST endpoint. The er

Re: Master/Slave failover for camel routes

Done a little more digging round this and I take if I invoke the following: *exchange.setProperty(Exchange.ROUTE_STOP, CustomFaultToleranceAPI.isInActive()); * >From RoutePolicy.onExchangeBegin() this will ensure the exchange on the warm instance will not be processed and yet the route will stay

Re: Master/Slave failover for camel routes

Unfortunately AMQ cluster,Zookeeper etc are not an option as I am constrained by internal approved tech stack. Joe -- View this message in context: http://camel.465427.n5.nabble.com/Master-Slave-failover-for-camel-routes-tp5758438p5758445.html Sent from the Camel - Users mailing list archive at

Master/Slave failover for camel routes

Hi My camel routes are packaged in a war and deployed on a tomcat server. From a failover strategy perspective I want to run hot/warm - same war deployed on 2 different tomcat servers. We have an inhouse fault tolerance component(not a camel component) which identifies which tomcat instance is th

Log component query

Hi Assume in my route I have the following line: DEBUG*"/> Now assume in my application that I have configured the category org.apache.camel.example to have a log level of *INFO*. Is it the case that it will only be in the route where logging for this category will be *DEBUG *and all logging fo

Re: JMS Component Query

Thanks for the response I tried that, i.e. changed my domain object to not implement Serializable and set jmsMessageType=Object in the JMS Endpoint but I get the following error: javax.jms.MessageFormatException: No type converter available to convert from type: com.fmrco.ptd.domain.BlockVO to t

JMS Component Query

Hi I have a route which is placing messages on to a JMS Queue. The JMS Message Type is ObjectMessage. Rather than having the IN Message Type implement Serializable is there any way in the DSL that I can specify the JMS Message Type. The object(IN Message Type) is a Domain Object and I would pref

Camel SEDA Queues performance query

Hi I have a route which returns messages from a DB call. It processes the messages and then places them on 2 different SEDA Queues. I have 2 additional routes which consumes the messages of the said queues and processes them. These 3 routes run very quickly( < 10ms). However, I have a 4th route

Transaction spanning multiple routes separated by seda queue

Hi I have a route to consume a message from a JMS Topic, do some processing on it and then place on a SEDA Queue. My second route will consume the message from the SEDA queue and place on a different JMS Topic. I want to ensure that the message only gets de-queued from the first Topic which it

Measuring time to make call to custom endpoint

Hi I have a simple route defined in the Spring DSL. .. Basically, I would like to output the time taken to call the custom endpoint. Hence, I was thinking of adding the current time as a header before the call to the custom endpoint and then comparing this date w

CXFRS Endpoint ignoring throwExceptionOnFailure property

Hi I am using the CXFRS Endpoint. I am using the following URI format: "cxfrs://bean://rsCustodyClient?throwExceptionOnFailure=true" My custody client bean looks like: http://localhost/service"; serviceClass="com.mycompany.rs.client.CustodyTradeResource" loggingFeatureEnabled="true" /

API to determine the last time a route was successfully executed

Hi If I hook up a JMX console to my camel application I can see a number of MBeans which expose information like the last time a route was successfully executed. Can I get this same information from the camelContext, Route, RouteContext etc. I can't appear to find a similar method which I can cal

Camel Quartz Query

Hi I have a quartz job(stateful) which wakes up every 60 seconds, pulls "unprocessed" records from a DB and sends each of them to a Web Service Endpoint. The Web Service call introduces a latency of approx .5 sec. Each time the quartz job fires there can be 100's of "unprocessed" records. Hence,

Re: Leveraging CXF Asynchronous processing when MEP is InOut

Hi I also had the same query. Would be very interested to hear any response on this query Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Leveraging-CXF-Asynchronous-processing-when-MEP-is-InOut-tp5735904p5736049.html Sent from the Camel - Users mailing list archi

Starting route defined in XML query

Hi I read somewhere in the past of a utility class provided by camel which you could use/call(e.g. from cmd prompt) to load a spring file which in turn would start up the xml defined routes. However, I cannot recall the name of it E.g. java org.apache...UtilityName spring-context.xml(which contai

Transaction spanning multiple threads query

Hi I have 2 routes. The first route calls a DAO method which makes a change to an Oracle database table. When done it places the message on to a seda queue. My second route picks the message from the seda queue and invokes another DAO method resulting in another change to an oracle table. My que

Camel quartz component query

Hi Assume I have a route which is using the quartz component(using the quartz database store). Is it possible at runtime to add new triggers. In other words, assume I have an ad-hoc route that I want to execute. If I configure this route to use the quartz component with the quartz database store

Calling a route which uses a quartz consumer via the producertemplate

Hi Assume I have the following route: *from(quartz..).to(...)* Now, assume I want to call this route out of the quartz schedule. I was hoping to be able to use the producertemplate. However, it looks like the quartz endpoint does not have a producer. Is there any other way I can invoke the abov

Database driven quartz triggers to manage HA in application

Hi I am planning on deploying 2 instances of my application to a cluster. I want both instances to be running in a Hot mode. Within my application I have a number of routes which are driven by a quartz scheduler. I was planning on using the database driven triggers for the quartz component. >Fro

Camel Cache Query

Hi Folks, If I have a route A which reads data from a dynamic source (data changes every x mins) and places it into a cache using the camel-cache component. I now have a route B that reads from the cache and sends the exchange to a bean where certain properties are set on the bean. Route B execut

Splitter and Aggregator Query

Hi If I am using the aggregator EIP in conjunction with the Splitter EIP do I have to specify a completion condition. In my case, when I split I don't know how many messages I am splitting. After splitting I need to aggregate all the messages again. Hence, unclear which completion condition I ca

Client acknowledgement support of Camel JMS component

Hi It appears using the client ack mode of the JMS component that the message will get de-queued if the route which consumes the message completes without throwing an exception. In my use case, my route consumes messages from a JMS topic and aggregates them using the aggregator EIP with a comple

JMS consumer aggregating messages and delivering to sub-system in batch mode

Hi I have a use case were I receive messages from a subsystem via a JMS topic. My applications needs to enrich these messages, aggregate them together and deliver them to another system via file based integration every 15 mins. I was thinking of using the aggregation eip and having the aggregatio

Exception policies query

Hi If I have an onException policy and I do *not *set the handled property to true then Camel will not break out of the route. If I have an onException policy and I set the continued property to true, Camel will not break out of the the original route either. So what is the difference between t

Re: Splitter EIP query

Thanks for the response. Yes I was planning on configuring quartz to be stateful. However, even if I configure it to be stateful I am assuming once I hit the splitter(assume message contains a list of objects) with parallelprocessing enabled the quartz thread will complete before the threadpool

ProducerTemplate Query

Hi Assume I use the producerTemplate to send an exchange to an endpoint(seda). Sending messages to this endpoint triggers a camel route which sends a message to a web service, e.g. Client code: Exchange response = producerTemplate.send("seda:testSeda" ExchangePattern.InOut,

Re: MEP Query

Thanks for the response. Sorry - 1 other question on this. If my route looks like: *from(endpoint1).to(endpoint2).to(endpoint3).to(endpoint4) * Assume the consumer for endpoint1 sets the MEP to InOut. If endpoint4 is a file endpoint what gets returned to the producer, i.e. the file endpoint only

MEP Query

Hi Assume I have the following route: *from(endpoint1).to(endpoint2).to(endpoint3).to(endpoint4) * What dictates the MEP on the exchange. Is it the consumer for endpoint1 since it creates the exchange? Or can the MEP change throughout the route, e.g. could the producer for endpoint3 change the M

Camel Exchange object query

Hi Assume the following route: *From Endpoint A -> Processor B -> Processor C -> Processor D -> To Endpoint E* >From my understanding, the consumer for Endpoint A is responsible for creating the exchange in this route. My question is - is it the same instance of the exchange object that moves

Singleton Endpoint Question

Hi If an endpoint is defined to be a singleton and you have 2 camel routes both referencing the same endpoint URI, will camel call endpoint.createConsumer() once or twice? Thanks Joe -- View this message in context: http://camel.465427.n5.nabble.com/Singleton-Endpoint-Question-tp5723464.html

Re: JMX attribute - Number of failures handled

Thanks If my route has an error handler with a retry attempt policy of 5 and a recoverable error is thrown in the route and on the 2nd attempt it is successful should the number of failures handled be incremented in this instance? Furthermore, if in the same route an error occurs and after the re

Re: JMX attribute - Number of failures handled

Thanks Assume an exception happens in my route and i have an error handler which places the message on a queue. In this instance would the *failures handled* increase or does it only increment via onException ()..handled(true).. syntax? Joe -- View this message in context: http://camel.465427

Camel type converter query

Hi I am trying to create a type converter that converts from a string to a domain object(Customer). The string is in the body of the in message of the exchange but I also need certain properties from the exchange to do the conversion Obviously the body of the in message(string in my case) of th

Wiretap query

Hi When I read documentation regarding the wiretap EIP it always looks like a copy of the exchange is sent to another endpoint in a different thread. Is it valid for me to wiretap and send to a number of endpoints sequentially? E.g. from("direct:start") .to("log:foo") .wireTap("bean:bea

Managing high availability with Camel

Hi I have an application which I need to have running in a cluster running primary/seconday(active/inactive) mode. When each instance of the application (A & B) starts up it connects to a proprietary application we have internally requesting to be primary. Hence, if A asks to be primary before B

error handling query

Hi I noticed that most endpoint consumers do something like the following: try{ getprocessor().process(exchange); } catch (exception e){ getExceptionHandler.handleException(); } Assume I have a route which consumes data from an endpoint whose consumer uses the above logic. Also assume that

Ordering of routes and ShutdownRoute.Defer option

Hi I am trying to ensure I understand the significance of the ordering of routes Assume I have route #1 which publishes messages on to a SEDA Queue, e.g. *from(endpoint).to(sedaQueue)* and I have route #2 which consumes messages from the same seda queue, e.g. *from(sedaQueue).to(endpoint)*. I

Shutting down my Camel Application

Hi I have a standalone application which embeds Camel. Most of the development is complete at this point and I have started to think about how best to manage the starting and stopping of the application. The application will needs to be stopped and started each day. I need to use a scheduler tool

Content Based Router Query

Hi The content based router does not appear to support the routing of a message to a particular destination based on a call to an external API. The examples I have looked at appear to support the routing of messages to a destination based on the message content. In a nutshell, I want to use a Con

Custom Component Query

Hi I have a custom component which has a ScheduledPollConsumer. The custom component pushes and consumes messages to/from a vendor product via a proprietary network API which the vendor has provided. If I have a network failure my consumer picks up on this straight away as it is polling a networ

Re: Exception handling in consumer for a custom endpoint

Hi Christian Thanks for the response. As rgds #2, I took a look at the ScheduledPollConsumer code like you said. If an exception occurs while calling the poll() method it appears to invoke PollingConsumerPollStrategy.rollback() to determine if we should call the invoke method again. However, i

Exception handling in consumer for a custom endpoint

Hi I have a custom endpoint/component. The consumer is a scheduledpollconsumer. I had a quick question on the behaviour of the *doStart() *and *poll() *methods which I implement in my consumer. Basically, the implementation of these 2 methods which I have provided in my consumer do quite a bit of

Re: Dynamic generation of Camel routes

Hi Folks Thanks for all the helpful responses on this item. Basically, I followed an approach similar to what Pontus outlined above. However, I have noted some strange behavior. When my application has started up the routes get added as follows: *context.addRoutes(new RouteBuilder().* Aft

Camel JMX Component query

Hi I need to interact with a vendor product which exposes a number of readable mbean attributes. Unfortunatly, no notifications exist for these attributes. I need to poll these managed attributes every 2 mins to see if any have updated. Since the JMX component does not appear to support polling

Exception handling in consumer of my custom component

Hi Assume I have a route which goes: *from("custom:component").process("").to("")..etc* Lets also assume I have an exception/error/retry policy set on this route. In my custom component consumer I need to invoke something like: * Exchange exchange = endpoint.createExchange(); exchange.getIn().se

Multicast and Aggregator V AKKA

Hi In my application I have 4 web service calls I need to make in a process flow which can be made in parallel.The obvious approach in solving this to me was just to use a multicast and have results aggregated together using the aggregator EIP support. Since I have been hearing much about akka la

Custom component query

Hi I need to create an event driven custom component. The sender which invokes the event driven consumer is a spring managed bean. My custom component consumer is not spring managed as this is obviously created from my endpoint which acts as a factory for my producers and consumers. Hence, I a

Dynamic generation of Camel routes

Hi I am working on an application were we need to build camel routes dynamically based on route configuration rules stored in a remote configuration store. My application makes a call to the configuration store, determines how many routes need to be built, retrieves the endpoint parameters and cr

Re: Testing a Route which de-queues message from Topic in CLIENT_ACKNOWLEDGE mode

Hi Folks It was also unclear to me how to ensure that the message was de-queued or not. Ideally, after starting up the broker service in my junit test I would like to put a message on to the queue and then verify I have successfully de-queued the message at the end of my testcase by ensuring the

Using advicewith to add interceptors to an existing route

Hi When I use the intercept feature below, is it legal to use wildchar's in the endpoint? Thanks Joe @Test public void testSimulateErrorUsingInterceptors() throws Exception { RouteDefinition route = context.getRouteDefinitions().get(0); route.adviceWith(context, new RouteBuilder(

Testing a Route which de-queues message from Topic in CLIENT_ACKNOWLEDGE mode

Hi I have a route where I consume a message from a JMS topic and do some processing of the message. I have the JMS Ack mode set to: CLIENT_ACKNOWLEDGE mode If the route successfully completes the message is dequeued. I want to verify that this takes place, i.e. message gets dequeued. Does the c

Camel JUnit Extensions + EasyMock

Hi I have a route which looks like: from("MyEndpoint").to("bean:MyProcessor").choice().when(*header("HeaderField").equals("Field1")*).when(*header("HeaderField").equals("Field2")*) The bean MyProcessor sets the "HeaderField". In my camel junit test class I load this exsting route. I would li

Unit testing of an existing RouteBuilder class

Hi I was reading how camel supports unit testing of an existing RouteBuilder class. I think this is very useful as I don't want to have to duplicate the route in the unit test. However, suppose the route defined in the existing RouteBuilder class contains an endpoint that I need to mock. Is th

Re: SEDA Request Reply

Hi So if I have the following 2 routes: from(SomeEndpoint).to("seda:endpoint"); from("seda:endpoint".to(SomeOtherpoint"); I have not specified the exchange pattern for the SEDA endpoint. Hence, does it default to something? Thanks -- View this message in context: http://camel.465427.n5.nabble

SEDA Query

Hi Assume I am consuming a message from a SEDA endpoint. Does the SEDA consumer support acknowledements to dequeue the message or is the message gone from the queue once my consumer gets it Thanks -- View this message in context: http://camel.465427.n5.nabble.com/SEDA-Query-tp5715082.html Sent

Re: Camel Component - Consumer Threading Question

Thanks for the response. I was just thinking about this a little further. If an exception occurs in my consumer, I really just need to restart the consumer not the whole route. If I take this approach, i.e. class CustomConsumer extends DefaultConsumer implements Runnable{ .. public void

Re: Camel Component - Consumer Threading Question

Thanks again 1 final question on this. If an exception occurs in the run method of the consumer, I want the endpoint, producer and consumer to be re-started. I was thinking of handling this as follows: class CustomConsumer extends DefaultConsumer implements Runnable{ .. public void run(){

Camel Lifecycle question

Hi I have a custom endpoint which has both a consumer and a producer. When a new instance of the endpoint and its producer and consumer is created I want to perform a particular action. I am trying to determine if there is any callback method on the endpoint, consumer and producer which might i

Re: Camel Component - Consumer Threading Question

Thanks for your input on this thread Claus. Just to confirm I understand you correctly, the Consumer would look something like: /class CustomConsumer extends DefaultConsumer implements Runnable{ ExecutorService service; CustomConsumer(EndPoint endPoint, Processor processor){ super(e

Re: Custom Camel Component instantiated twice

So if there can be multiple Consumer & Producer instances in a given context (one per route reference), this would imply that there could be multiple instance of the Endpoint(again one per route reference)? I have a custom component where I need to share state between the producer and the consumer

Camel Monitoring Tool

Hi We are planning on using Camel for a large scale, real-time, critical system. We are investigating which tools (opensource and vendor) are available to view the usage patterns of our routes - volumes of messages etc, identify bottlenecks in our routes etc Just wondering if anybody could recom