Hi,
I'm wondering if it is possible to recover from the case where someone
Cntrl-Cs a process that uses an aggregator.
For example, I have an aggregator with a batchTimout set to 5 minutes. If
someone Cntrl-C's the program at 2 minutes, the messages that have been
consumed up to that point are
Camel iBatis componet is just very simple wrapper around Apache iBatis
library which very close to JDBC by performance and time assumption. Is JDBC
can manage your real time? I don't know exactly.
On Fri, Oct 23, 2009 at 9:41 PM, titexe wrote:
>
> Hello,
>
> We would like to copy in real time th
Hello,
We would like to copy in real time the inserted records in a database to
another,
my question is: the component ibatis camel can manage this mode(real time)?
Best regards,
titexe
PS : I bought your book camel in action, it has served me well, I wish you
good continuation
--
View this
On Fri, Oct 23, 2009 at 6:35 PM, Paul Phillips wrote:
>
> Hi there
>
> bit of a beginner question here.
>
> I have a situation where I want to
>
> - get some xml from a jms queue
> - send an id contained in the xml to a custom component i have written (the
> body of the request should be a string
2009/10/23 Paul Phillips :
>
> Hi there
>
> bit of a beginner question here.
>
> I have a situation where I want to
>
> - get some xml from a jms queue
> - send an id contained in the xml to a custom component i have written (the
> body of the request should be a string that looks like this: "ID=bl
Hi there
bit of a beginner question here.
I have a situation where I want to
- get some xml from a jms queue
- send an id contained in the xml to a custom component i have written (the
body of the request should be a string that looks like this: "ID=blah", so I
use a bean to grab the id using
That's great!
I'm a camel newbie so I'm sure this book will be very helpful.
Thanks and keep us all posted.
-Russ
-Original Message-
From: Claus Ibsen [mailto:claus.ib...@gmail.com]
Sent: Thursday, October 22, 2009 2:20 PM
To: users@camel.apache.org
Subject: Announcing Camel in Actio
Hello,
I ended up solving this problem with the follow configure method:
private void configureNewsTrackerByTeamHtml() throws Exception {
for(String url : urls){
from("atom://"+url+"?splitEntries=false&consumer.delay="+co
On Fri, Oct 23, 2009 at 3:23 PM, chris.pond wrote:
>
>
>
> Claus Ibsen-2 wrote:
>>
>> I think you have the from topic as a JMSDestination header on the message.
>> But I havent checked
>>
>> Destination topic = exchange.getIn().getHeader("JMSDestination",
>> Destination.class);
>>
>> --
>> Claus I
Claus Ibsen-2 wrote:
>
> I think you have the from topic as a JMSDestination header on the message.
> But I havent checked
>
> Destination topic = exchange.getIn().getHeader("JMSDestination",
> Destination.class);
>
> --
> Claus Ibsen
> Apache Camel Committer
>
> Author of Camel in Action:
On Fri, Oct 23, 2009 at 1:56 PM, Willem Jiang wrote:
> Oh, it's a typical mock API usage.
> You need to set up the mock behavior (assertion) before doing the actual
> invocation.
> Then call the verification to check the assertion.
>
Yeah read chapter 5 in Camel in action again :)
> Willem
>
>
On Fri, Oct 23, 2009 at 1:55 PM, DulmerLucsly
wrote:
>
> Hi erverybody,
>
> i have a little problem with exceptionhandling.
> Since i'm new to activeMq/Camel sorry if the question is trivial...
>
> I try to build a route with java DSL. My route looks like this:
>
>
> public void configure() {
Oh, it's a typical mock API usage.
You need to set up the mock behavior (assertion) before doing the actual
invocation.
Then call the verification to check the assertion.
Willem
Charles Moulliard wrote:
I have found the reason : the line
"template.sendBody(Model.generateModel(
EmxMessageType
Hi erverybody,
i have a little problem with exceptionhandling.
Since i'm new to activeMq/Camel sorry if the question is trivial...
I try to build a route with java DSL. My route looks like this:
public void configure() {
from("jms:fileIn?transacted=true")
.onException(UnmarshalExcepti
I have found the reason : the line
"template.sendBody(Model.generateModel(
EmxMessageType.VRES.getValue(), Model.getInVresMessage()) );"
must be put after "resultEndpoint.expectedBodiesReceived( expected );"
Why : I DON'T KNOW
@Test
@DirtiesContext
public void testModeltoCsv() throws E
I have also this issue with the following test (the code is based on
what I have done in camel-bindy where there are 25 unit tests like
this one) :
@Test
@DirtiesContext
public void testModeltoCsv() throws Exception {
template.sendBody(Model.generateModel(
EmxMessageT
Yes. Everything works fine except that endpoint receives null.
Charles Moulliard
Senior Enterprise Architect
Apache Camel Committer
*
blog : http://cmoulliard.blogspot.com
twitter : http://twitter.com/cmoulliard
On Fri, Oct 23, 2009 at 12:40 PM, Willem Jiang wrote:
I don't know why the resultEndpoint can't receive any message.
chris, are you using spring configuration.
Can you check if the resultEndpoint is injected rightly?
Willem
Claus Ibsen wrote:
The B[ stuff is Java way of telling its a byte array
Force Camel to test against String etc
//
How can I receive the byte[] from the message ?
I suppose that the following method call will return an object :
resultEndpoint.getExchanges().get(0).getIn().getBody()
Charles Moulliard
Senior Enterprise Architect
Apache Camel Committer
*
blog : http://cmoulliard.blog
The B[ stuff is Java way of telling its a byte array
Force Camel to test against String etc
>// resultEndpoint.expectedBodiesReceived(result);
Could be
resultEndpoint.message(0).body(String.class).isEqualTo(result);
I guess we should add that type converter stuff into
expectedB
I have created a unit test to unmarshal a FIX message into a model
(copy the model into another one) and marshal the result into a CSV
The result received by the mock is null. If I try to read the object,
I have this :
>>> Class : [B
>>> CSV generated : [...@12b19c5
Remark : the FIX message is w
Hi
See this unit test which I have created that works.
http://svn.apache.org/viewvc?rev=828961&view=rev
On Wed, Oct 21, 2009 at 8:15 PM, Wilson wrote:
>
> Hi Claus,
>
> Thanks for your answer.
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> Do you "loose" message every time you run the unit test?
>>
Hi
Also use option concurrentConsumers on the JMS endpoint to support
concurrency, instead of threads.
On Wed, Oct 21, 2009 at 2:58 PM, Claus Ibsen wrote:
> Hi
>
> Maybe this ticket can give some hints
> https://issues.apache.org/activemq/browse/CAMEL-490
>
> On Wed, Oct 21, 2009 at 2:15 PM, Er
On Wed, Oct 21, 2009 at 2:31 PM, linuca wrote:
>
> Hi,
>
> I tested the resquest/replay example from ActiveMQ (without using Camel) and
> it worked fine, so I don't think there is something wrong with the
> connection.
>
> So I assume there is something wrong with my Camel code? Can anyone tell me
On Thu, Oct 22, 2009 at 11:30 PM, chris.pond wrote:
>
> I'm trying to take JMS messages inside the ActiveMQ broker from a topic
> pattern, say "messages.*", and map them to a corresponding JMS queue, say
> "queue.${from.topic}" (where ${from.topic} is the topic of the JMS message).
> I can't seem
25 matches
Mail list logo
