Apache Camel Threading Model

Hi, I have a basic question about how framework processes the messages. If i have something like this: In this case i have multiple processors for the message. Would this processing be serialized or Camel will send the message in parallel to each processor ? Thanks -- View this message in

Apache >> Camel >> Netty --> How to Know Client Disconnection

I am using Camel netty component as a consumer binding to IP and port... Are there any callback methods to know when a client connects and disconnects ? -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Netty-How-to-Know-Client-Disconnection-tp5646718p5646718.html

Re: AGGREGATION Properties

I was not doing it in the right way. I got the properties i required. I was able to get the Property for composite key for CamelAggregationCorrelationKey from e.getproperties() -- View this message in context: http://camel.465427.n5.nabble.com/AGGREGATION-Properties-tp5611236p5611418.html Sent f

AGGREGATION Properties

Can somebody please let me know what values are expected out of Exchange properties AGGREGATED_CORRELATION_KEY and AGGREGATED_COMPLETED_BY. I see it has the value CamelAggregatedCorrelationValue and CamelAggregatedCompletedBy that are not useful. How can i get the real key values on which the aggre

Aggregation EIP

I am trying to use Multiple Aggregates on a single header wherein each of the aggregate picks up different fields from a header to do the aggregation. Once the aggregation is done and all are sent to the next component in the route, is there a way to figure out what aggregate came from which header

Re: Apache >> Camel >> Aggregation EIP

Thanks Christian. Can you please point me to some documentation where i can find the syntax for things like these about what all can be put in Spring DSL and how. -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Aggregation-EIP-tp5596001p5596487.html Sent from th

Re: Apache >> Camel >> Aggregation EIP

Yes, maybe a composite header and i need to know how can i specify a composite header in Spring DSL. My Need is simply that the aggregation should happen on 2 or more keys rather than one. For example, the aggregation should take place on 2 keys - CustomerId and BillingId. -- View this message

Apache >> Camel >> Aggregation EIP

How can we configure multiple headers in the correlationExpression for aggregate EIP? Currently I have dictionary Can i specify multiple headers as the co-relation key ? -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Aggregation-EIP-tp5596001p5596001.html Sen

Re: Apache >> Camel >> Missing Headers

Thanks. I went through it and was very helpful in understanding what was happening. -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Missing-Headers-tp5595800p5595971.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Apache >> Camel >> Missing Headers

The issue i found was that in one of the beans i modify the body of the message. After that the header is lost. But if i set back the header in the same bean where i modify the body, then header is propogated. I did e.getOut.setHeaders(e.getIn().getHeaders()) it works after i do this -- View thi

Apache >> Camel >> Missing Headers

When i am routing a message from endpoint to a "bean", i can't access the headers i set. Is this the way it works ? -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Missing-Headers-tp5595800p5595800.html Sent from the Camel - Users mailing list archive at Nabble.com

Re: Apache >> Camel >> Time based Message Routing

Thanks. This looks like the pattern I need. -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Time-based-Message-Routing-tp5593850p5594006.html Sent from the Camel - Users mailing list archive at Nabble.com.

Apache >> Camel >> Time based Message Routing

I want to implement and end-to-end chain in which Component A sends a routes to component B. Component B aggregates the statistics for an interval(e.g 15 minutes). When the 15 minutes elapse then Component B routes to component c. This means routing between component B and Component C is once every

Re: Apache >> Camel >> ActiveMq

It doesn't work even if i just send the message directly from netty endpoint without modifying the body -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-ActiveMq-tp5580552p5587190.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Apache >> Camel >> ActiveMq

it is just a test for now. kpigeneratorBean simply sets a test message "From KPI Bean" in the body of the message. Basically it has just 1 line: e.getOut().setBody("From KPI Bean"); In fact if i route the message directly from netty component to the queue, i still get the error. -- View this mes

Re: Apache >> Camel >> ActiveMq

In fact the trace i sent already is when it makes second delivery attempt and after. In the first delivery attempt the trace is as below. It seems that messages are simply not being delivered to the ActiveMQ queue == TRACE ===

Re: Apache >> Camel >> ActiveMq

Camel Version 2.9.0. I am trying to run these routes for first time and i am getting this exception at the start of the routes itself. Everything is configured in the xml file. I am pasting full xml file followed by complete stack trace: http://www.springframework.org/schema/beans"; xmlns:

Apache >> Camel >> ActiveMq

I am getting an exception when starting the routes that has ActiveMq component in it. It is complaining about not able te resolve the reply Destination. What setting am i missing ? The exception is: Failed delivery for exchangeId: ID-NCPC5MTVC91-4021-1332260165476-0-6. Exhausted after delivery att

Re: Apache Camel >> Netty

Thanks. I have it working now. It was just a mismatch of encoders/decoders. -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Netty-tp5545678p5565388.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Apache Camel >> Netty

What do i need to consider when I have a Netty consumer on Camel side and i want somebody to send me messages over the socket so. Meaning i have a netty consumer, for example, as below. The program sending me the messages over the socket isn't a camel component but a plain netty program. When i sen

Re: Apache Camel >> Netty

Yes, i think i can add the concession to have Camel netty component as consumer. -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Netty-tp5545678p5558173.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Apache Camel >> Netty

Yes, the issue was related to Context not up and now it works fine. I have a need to create a binary stream over the TCP connection. Means , in client server mode, I want to send a message to the server(that will run on a particular ip/port) over TCP socket to say "start" and then server should sta

Re: Apache Camel >> Netty

What i see is that the URL gets screwed in producer template. In the exception you can see URL as netty://tcp://localhost:1521?sync=true whereas it should have been netty:tcp://localhost:1521?sync=true -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Netty-tp5545

Re: Apache Camel >> Netty

Camel 2.9.0 -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Netty-tp5545678p5545791.html Sent from the Camel - Users mailing list archive at Nabble.com.

Apache Camel >> Netty

First time Camel User and trying to use Netty Component. I was running some of the sample code from Netty test in my own classes and got an exception from this statement. I am looking at it to figure out the problem but i do appreciate any help. Poetry response = (Poetry) producerTemplate.requestB