Re: Splitter and combining messages / exchanges

What about using the stream component instead of a splitter? You could then route to a bean and keep the first line in ThreadLocal or something like that, and do the aggregation in the bean. You could not doing any asynchronous processing in this case do to using the ThreadLocal. This might not

Re: Splitter and combining messages / exchanges

Hi Jason, that was my first idea, too. But this does not work. Because I need the streaming mode (big file) I need to "release" every line from from the Aggregator immediately, e.g. the "completion predicate" will be true for all lines but the first. And when an aggregated Exchange is "completed"

Re: Splitter and combining messages / exchanges

I believe could write a custom aggregator. On the first call, you put the "Hello" into a header on the Exchange and return that Exchange. On the rest of the calls, you can read the header and aggregate it with the current body. On 11/30/12 2:33 PM, "Oliver Geisser" wrote: >Hi Claus, > >thanks

Re: Splitter and combining messages / exchanges

Hi Claus, thanks for your help. I've checked the Composed Message Processor EIP. Maybe I'm missing something but as far as I can see the EIP will not work for my use case. Let's recap my problem with the input file Hello A B C ... Because it's a very large file it will be splitted in streaming

Test Intercept with adviceWith and http

Hi, This time I tried using http instead of http4. No exception, but the intercept is not working, even with isUseAdviceWith() to return true. What is going on ? using camel 2.10.2, and http 4.2.2. Thank you in advance, import org.apache.camel.Exchange; import org.apache.camel.Processor; impor

Re: camel standlaone application deployment in clustered enviornment

As camelContexts are independents from each other, you can deploy your application in different JVM and on different servers, there will never be in conflict. Nevertheless take care if your endpoints consume the same resources (files, ...) as they will be in competition in this case. On Fri, Nov

Re: Dead letter queue when header not matched?

Scott, Cheers that makes perfect sense, however I wanted to test was the actual errorHandler part from first post. I'll use the otherwise to handle incorrect headers but I want to maintain the errorHandler for unforeseen problems. I was wondering if there is a way to force a message to hit the err

Re: Dead letter queue when header not matched?

You can have a mock route that is a consumer of the DLQ just as you would have a mock route for the happy path. Here is a short example: from("seda:start") .choice() .when(header("type").isEqualTo("A")); .to("direct:end") .otherwise() .to("direct:my.DLQ") .routeId("myRoute")

Re: Dead letter queue when header not matched?

Cheers, that's very helpful. I have another related question; I want to unit test my actual dead letter queue, whats the easiest way to mock a broken communication to demonstrate this? Thanks again. -- View this message in context: http://camel.465427.n5.nabble.com/Dead-letter-queue-when-head

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

Dead letter queue when header not matched?

For the following: errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(1).redeliveryDelay(100)); from("seda:start") .choice() .when(header("type").isEqualTo("A")) .to("direct:end") .routeId("myRoute"); How would I configure the route to send the message to the deadLet

Re: Speed up marshalling objects to XML by explicitly loading classes

> Is there a way to speed up first request and explicitly load all generated > classes when I deploy my bundle? If loading these 1000 classes by classloader is the issue, then you can use Reflections [1] and eager loaded Spring bean to load all these classed when bundle context starts up. R

Re: Problems unmarshalling with Java serialization (ClassNotFoundException)

Hi, I've already sent another mail to mailing lists without any response :) Here is what i was saying : I'm trying to unmarshal with serialization method a bean that is not the current bundle but in a commons components bundle (with only pojo within). I get the following error when camel tries t

Re: Camel multicast configuration file

Hi Bala, > I am trying to configure camel multicasting in my project. The requirement > is to hit multiple services in parallel and consume the response. As Claus suggested you forgot to aggregate the requests. And here's how can you aggregate responses from multiple services: from("direct:serv

Re: Problems unmarshalling with Java serialization (ClassNotFoundException)

> reading this title, i think i may have a similar problem. > Do you have any solution ?? :) :) Hi, You're referring to the post older than year and which have been removed from the Nabble archive. :) Please describe your problem so we could help you :) . -- Henryk Konsek http://henryk-konsek

Re: [FTP2] Problems transversing directories when uploading files with SFTP (Camel 2.9.4)

Ainda, Do you have the correct permissions on the server? Best Regards Leandro Franchi On Fri, Nov 30, 2012 at 11:50 AM, Aida wrote: > Hi, > > I have been having trouble trying to upload files using a sftp endpoint. > > The way I'm working to upload a file is using a ProducerTemplate ( > Pro

[FTP2] Problems transversing directories when uploading files with SFTP (Camel 2.9.4)

Hi, I have been having trouble trying to upload files using a sftp endpoint. The way I'm working to upload a file is using a ProducerTemplate ( ProducerTemplate.send(endPointDefinition, data2write) where data2write is the Exchange with the data I want to upload ). This way works for me working w

Failover with Camel CXF

Hello, I have many routes with many components like Activemq and CXF. I'm using the failover protocol to loadbalance Activemq brokers and CXF webServices. *The sysntax : failover:(tcp://server1:61616,tcp://server2:61616)* is working and messages routed to one broker when the other is down.

Re: Jackson custom configuration

Thanks, I'll keep my eye on it. I'll check source codes too, to get idea how it works. On Fri, Nov 30, 2012 at 1:21 PM, Claus Ibsen wrote: > Hi > > I have logged a ticket about this > https://issues.apache.org/jira/browse/CAMEL-5836 > > On Tue, Nov 27, 2012 at 10:30 AM, Martin Stiborský > wrot

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: Speed up marshalling objects to XML by explicitly loading classes

Hi No there is not. Maybe if you specify a JAXB data format, and with the contextPath, then JAXB may load these on startup. Not sure though. On Tue, Nov 27, 2012 at 12:07 PM, Ben V wrote: > I have lots of xsd and create java classes from them (~1000 classes) using > xjc and deployed them to S

Re: Jackson custom configuration

Hi I have logged a ticket about this https://issues.apache.org/jira/browse/CAMEL-5836 On Tue, Nov 27, 2012 at 10:30 AM, Martin Stiborský wrote: > Hello guys, > how it's possible configure in general Jackson in Camel? > For example, I need to use indentation/DefaultPrettyPrinter for all > marshal

Re: Spring Transaction Propagating?

Not sure I follow (I'm newish to Camel and Spring TX). So basically it can't be done, so I'll be better off setting up functionality so that I can start my transaction at the consumer method rather than the producer to avoid changing thread during the transaction? Cheers for the help. -- View t

Re: Spring Transaction Propagating?

On Fri, Nov 30, 2012 at 12:41 PM, tolk wrote: > I noticed Camel has some functionality relating to transactional behaviour. > Is this just internal transactional behaviour then i.e. only over the camel > communication itself? > No it integrates with Spring TX. And ensures the route is run under t

Re: Spring Transaction Propagating?

I noticed Camel has some functionality relating to transactional behaviour. Is this just internal transactional behaviour then i.e. only over the camel communication itself? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/Spring-Transaction-Propagating-tp5723442p5723

Re: aggregator issue

On Thu, Nov 29, 2012 at 12:09 PM, Jason Chaffee wrote: > I have a custom aggregator strategy but for some reason the oldExchange is > always null. Any ideas? > > > Here is my route. > > from("seda:Split") > .routeId("Split") > .aggregate(new MyAggregationStrategy()) > .c

Re: issue with jsonFormatting and timestamps

I logged a new ticket just in case we didnt have that ticket I think we have https://issues.apache.org/jira/browse/CAMEL-5836 On Fri, Nov 30, 2012 at 12:25 PM, Claus Ibsen wrote: > Hi > > Yeah I think we may have a JIRA ticket to improve the json data format > to allow to configure it. > > Frankl

Re: issue with jsonFormatting and timestamps

Hi Yeah I think we may have a JIRA ticket to improve the json data format to allow to configure it. Frankly we should maybe let json default be jackson. And add ways to configure it, so you can set custom serializers etc. On Thu, Nov 29, 2012 at 11:12 PM, Marco Mistroni wrote: > Hello all >

Re: Spring Transaction Propagating?

Hi No you can't propagate spring TX accross different threads. On Fri, Nov 30, 2012 at 12:01 PM, tolk wrote: > I have a situation similar to the simplified example below. Basically, I'm > trying to use camel on an internal service to send an async message to > itself via the SEDA component - a

Spring Transaction Propagating?

I have a situation similar to the simplified example below. Basically, I'm trying to use camel on an internal service to send an async message to itself via the SEDA component - a little odd perhaps but I don't have any choice in this: public class MyServiceImpl { ProducerTemplate producer

Transactions, Error, Stop route

Dear All, I would like to discuss/have some advice on the following: Functional requirement: In case an error occurs in our route while while processing a message from ActiveMQ queue. We want the message to return back to the queue and the route to stop working. Technically we think we need a co

Re: aggregator issue

> I want to merge the message bodies into a container object. I would use GroupedExchangeAggregationStrategy and then forward the results of the aggregation to the processor. from("direct:aggregateMe"). aggregate(constant(true),new GroupedExchangeAggregationStrategy()). completionSize(2). .