Hi
See the eip docs
http://camel.apache.org/multicast.html
And read about the aggregation strategy.
On Fri, Nov 30, 2012 at 6:36 AM, Bala wrote:
> Hi Team,
>
> I am trying to configure camel multicasting in my project. The requirement
> is to hit multiple services in parallel and consume the r
Hi
See this EIP
http://camel.apache.org/composed-message-processor.html
On Thu, Nov 29, 2012 at 11:27 PM, Oliver Geisser
wrote:
> Hello,
>
> I am using a splitter to handle a big txt file (streaming mode). I need to
> combine the first line
> with all the other lines and store each result into a
On Thu, Nov 29, 2012 at 5:46 PM, Sébastien Foubert
wrote:
> Hi,
>
> I use a timer based pooling consumer like this,
> http://camel.apache.org/polling-consumer.html#PollingConsumer-Timerbasedpollingconsumer
>
> The difference is that to consume messages, i use a jms selector like this
> * String m
On Fri, Nov 30, 2012 at 1:04 AM, Grant Sheppard
wrote:
> Further to what I previously wrote, to me at least the root cause seems to be
> that the Spring context is shutdown immediately regardless of whether you've
> specified a shutdown timeout for the Camel context.
>
> Does anyone know whether i
Hi
Yes see this FAQ and the links it has, and you will find what you seek
http://camel.apache.org/running-camel-standalone.html
On Thu, Nov 29, 2012 at 11:20 PM, Tyler Durvik wrote:
> I have always used maven in development and generated projects using
> the maven "archetype:generate" target.
Hi there,
the functionality for your need is available now, check the trunk.
Here is the thread when you can read more:
https://issues.apache.org/jira/browse/CAMEL-5724
Best regards,
Andrej
--
View this message in context:
http://camel.465427.n5.nabble.com/Re-Using-WebServiceMessageCallbac
Hi Team,
I am trying to configure camel multicasting in my project. The requirement
is to hit multiple services in parallel and consume the response. When I
tried, am getting the response in body of the second service alone. Am not
able to get the response of the first service. Please help me on t
Using camel 2.10.
I have a route similar to the following:
java.lang.Exception
false
I really don't want grouped exchanges, that is if I understand them
correctly. I want to merge the message bodies into a container object.
In a nutshell, I am loading a third-party XML file, splitting it into
individual items, normalizing those items into my objects, and then I want
to aggregate
I have always used maven in development and generated projects using
the maven "archetype:generate" target. I have performed those steps
again on my current project but now I want to load the XML
configuration file containing the Camel Context and route definitions
from a Main java class. Is ther
Hi,
reading this title, i think i may have a similar problem.
Do you have any solution ?? :) :)
Thx
--
View this message in context:
http://camel.465427.n5.nabble.com/Problems-unmarshalling-with-Java-serialization-ClassNotFoundException-tp1044690p5723419.html
Sent from the Camel - Users mai
Hello all
i have a serverside camelapp in which i am exposing an http channel
which returns json data.
the problem i have is that one of the object i serialize contains a
timestamp, and this is how the object is beign serialized
[{"title":"[video] Tablet Boom: A Derivative
Play?","description":
Hi Jason,
> Here is my AggregationStrategy:
Your custom aggregation strategy acts like
GroupedExchangeAggregationStrategy. Why don't use the latter then?
from("direct:aggregateMe").
aggregate(constant(true),new GroupedExchangeAggregationStrategy()).
completionSize(2).
.setBody(property(Exc
Same issue.
By the way, here is my route sends the split message to the "seda:split".
from("file://./target/?fileName=raw.xml")
.routeId("FileIngest")
.split()
.tokenizeXML("offer")
.parallelProcessing()
.streaming()
.unmarshal().jaxb("com.otherCompany.ingest.model"
Do you observe the same behavior if you start your camel route with direct
component (from("direct:a")) ?
On Thu, Nov 29, 2012 at 6:47 PM, Jason Chaffee wrote:
> It is doesn't complete until after some 20,000 calls, I confirmed that is
> correct. However, the oldEchange is null for every single
It is doesn't complete until after some 20,000 calls, I confirmed that is
correct. However, the oldEchange is null for every single one of them.
On 11/29/12 4:22 AM, "Claus Ibsen" wrote:
>oldExchange is null on the 1st call.
>
>Maybe you completion triggers because there is only 1 exchange in
Hi,
I am trying to intercept a message to skip the Http request and proceed with
my route.
Here is the class you can copy/paste to try it out.
Return false in isUseAdviceWith() : The test is success but the message is
never intercepted.
Return true in isUseAdviceWith() : I get this exception :
o
Hi,
I use a timer based pooling consumer like this,
http://camel.apache.org/polling-consumer.html#PollingConsumer-Timerbasedpollingconsumer
The difference is that to consume messages, i use a jms selector like this
* String message =
consumer.receiveBody("activemq:com.xxx.esb.myqueue?selector=JM
Using 2.10.2
--
View this message in context:
http://camel.465427.n5.nabble.com/Intercepting-message-for-testing-not-working-tp5723257p5723400.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Thanks Claus. I will try that.
-Original Message-
From: Claus Ibsen [mailto:claus.ib...@gmail.com]
Sent: Thursday, November 29, 2012 10:53 AM
To: users@camel.apache.org
Subject: Re: creating .camelLock extension on file using custom
GenericFileProcessStrategy
On Thu, Nov 29, 2012 at 4:3
On Thu, Nov 29, 2012 at 4:32 PM, Kesireddy, Chandana (ITD)
wrote:
> Claus,
>
> Thanks for replying.
> So in the begin method , I need write code to create an empty file with
> .camelLock extension and return true.
>
> In commit method I need to write code to delete both the original file and
Claus,
Thanks for replying.
So in the begin method , I need write code to create an empty file with
.camelLock extension and return true.
In commit method I need to write code to delete both the original file and
.camelLock file, so that It won't get processed again.
Please correct me If m
On Thu, Nov 29, 2012 at 4:00 PM, Kesireddy, Chandana (ITD)
wrote:
> Thanks for replying.
> My problem here is , it's not creating .camelLock extension on the file when
> it is processing the file, using custom GenericFileProcessStrategy.
> What do I need to do in order to make it create .camelLoc
Thanks for replying.
My problem here is , it's not creating .camelLock extension on the file when it
is processing the file, using custom GenericFileProcessStrategy.
What do I need to do in order to make it create .camelLock extension on the
file.
Thanks,
Chandana
-Original Message-
Fr
On Wed, Nov 28, 2012 at 10:44 PM, Kesireddy, Chandana (ITD)
wrote:
> Hi,
>
> I am writing custom GenericFileProcessStrategy class . Iam not able to
> create .camelLock extension on the file when it processes the file.
> I want the file to be deleted after it is processed.
Camel will normally d
oldExchange is null on the 1st call.
Maybe you completion triggers because there is only 1 exchange in the batch.
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 rou
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())
.constant(true)
.completionFromBatchConsumer()
.completionP
On Thu, Nov 29, 2012 at 10:12 AM, Hildegard Schedthelm
wrote:
> Hello Claus!
>
> Thanks a lot for helping.
>
>
> I cannot conceive how a different poll interval can help to start polling at
> all.
>
> The ftp component derived from the file component that has the batch consumer
>
> implemented to
Hello Claus!
Thanks a lot for helping.
I cannot conceive how a different poll interval can help to start polling at
all.
The ftp component derived from the file component that has the batch consumer
implemented to poll multiple exchanges. When I start downloading e.g. about 10
files from
On Wed, Nov 28, 2012 at 4:43 PM, dunnlow wrote:
> Claus, I understand that is what the exception indicates; However, as you can
> see from my code above (which is the actual code from the test) that I have
> declared the header a Map and am setting the value to the
> string "John." Thus, I'm conf
Hi All,
I wanted to deploy camel stand alone application in clustered environment.
I am loading camel context thru a spring main class.
If i have to deploy this stand alone application on 4 nodes.
Do I have to change anything?
If i follow what i am doing then I will have 4 jvms & 4 camel co
31 matches
Mail list logo
