Created a custom IdempotentRepository implementation that uses MongoDB for
storing idempotent keys. It implements the
org.apache.camel.spi.IdempotentRepository interface.
Noticed that the contains method is not called when setting the eager option
to true. It seems to be the opposite to the javado
Its very likely related to that you use transacted so all messages
that are sent to a jms queue from the same TX (eg using the same
thread which is required by spring tx manager to orchestrate in same
tx). and hence only when the tx is committed at the end, the messages
you sent to the jms queue is
Hi
Yeah that is a mistake in the javadoc. I have corrected that for
upcoming releases.
For eager mode, its add and confirm that are called.
For non-eager mode its contains and add that are called.
.. and if the message failed, then its remove that are called instead
of confirm/add.
On Thu, Feb 2
Hi
I logged a ticket
https://issues.apache.org/jira/browse/CAMEL-7228
On Wed, Feb 19, 2014 at 10:46 PM, mads64738 wrote:
> Hello,
>
> We have been undertaking an upgrade from Camel 2.9.1 to Camel 2.12.2, and in
> most cases, the upgrade has been very smooth.
>
> Unfortunately, we have spotted a
Hi Claus,
Sorry for the late reply.
I wrote a simple code to test this behaviour:
CamelContext con = new DefaultCamelContext();
ConsumerTemplate template = con.createConsumerTemplate();
template.start();
int i = 0;
while (i < 100) {
Excha
Hallo all,
I want to turn below spring DSL way into java DSL way.
is there any example for reference?
http://localhost:{{port}}/GreeterContext/SOAPMessageService";
wsdlURL="wsdl/hello_world.wsdl"
endpointName="s:SoapOverHttpRouter"
serviceNa
And when I call template.stop(),all the threads are destroyed.
From: Chirag Dewan
To: "users@camel.apache.org"
Sent: Thursday, 20 February 2014 3:23 PM
Subject: Re: OOM issue due to MemoryIdempotentRepository
Hi Claus,
Sorry for the late reply.
I wrote
Hi
That is because the endpoint uri, is unique, eg you put the index in there.
Then the endpoint cannot be reused for next poll.
See this FAQ how you can lower the pool size
http://camel.apache.org/how-do-i-configure-the-default-maximum-cache-size-for-producercache-or-producertemplate.html
You c
Hi,
After setting the max cache for consumer template the threads are now in
WAITING state instead of TIMED_WAITING state.
Actually I want to consume a single file with a filename in my application. So
once a file is consumed,that endpoint cannot be reused and for every file a new
endpoint is
Messages are not regarded as in-flight while they are holded by aggregator.
On Mon, Feb 10, 2014 at 3:16 PM, chessami92 wrote:
> Hello there,
>
> I am using camel 2.12.2, and I seem to be running into an issue where
> messages are being dropped on graceful shutdown. I've given a sample
> testng/
Hi Claus,
Many thanks - much appreciated. For now, we've left our "downloader"
processes on Camel 2.9.1, so will be interested in a fix, when available.
Best regards, Madhu.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-2-12-HTTP4-Now-seeing-port-number-added-to-Ho
Hi Claus, thanks for your answer. Yeap, this one.
Already checked the tests
(https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tree;f=components/camel-aws/src/test/java/org/apache/camel/component/aws/swf;h=61f18111883ef7c135765f41f8d3b9bfa71abf94;hb=refs/heads/master)
and could'nt find anythin
My requirement on batch file processing:
1. Reading csv file with a header
2. process each record (except header) involving DB [prefer bulk commit]
3. write each responses to a another file with a header
Solution can be modeled with Spring Batch easily, but I am looking for a
solution with apac
Hi,
wouldn't it make sence to number the seg1 seg2 files like hadoop numbers
the parts
i.e.
seg001
seg002
etc.
Further it would make sence for me to be able to put some date / timestamp
part in the base path, so that for example every day the seg counter is
reset and the files are writt
> thanks for the hint. I reduced the file to 4 pages (attachment Form-...).
I can't see the attachment. :)
BTW Are you using standalone Camel or some concrete product (like JBoss Fuse?).
Cheers.
--
Henryk Konsek
http://henryk-konsek.blogspot.com
Transactions do seem to be the reason it's behaving this way. I don't have
much experience with transactions at this point, so I'm a bit ignorant on
the subject.
This may not be the correct place to go into detail about this, but I
thought I read somewhere that the boundary of a transaction can't
Hello Claus,
I have created an FTP Client with Camel but the ftp server that we connect
to has a really low response time. Therefore I would like to allow the FTP
client to set up multiple connections to the same ftp server. Is there a
way to set this up within Camel?
ftpString = "ftp://"; + ftp
Sorry, I should have included the version in my original post.
I'm using Camel version 2.12.2. with ActiveMQ broker 5.9.0
--
View this message in context:
http://camel.465427.n5.nabble.com/sjms-component-ttl-does-not-seem-to-work-tp5747604p5747666.html
Sent from the Camel - Users mailing list
Hello,
I would like to offer a main webservice which gets a http request with xml
payload.
After unmarshalling with JAXB I want to split (splitterBusinessLogic) the
request into 2 subservice requests with dynamic target url's.
Therefore I use a dynamicRouter (with MyDynamicRouter.class).
Finally
The ftp consumer in Camel is single threaded.
There is a information box at this page that tells that
http://camel.apache.org/ftp2
On Thu, Feb 20, 2014 at 2:49 PM, Rick89 wrote:
> Hello Claus,
>
> I have created an FTP Client with Camel but the ftp server that we connect
> to has a really low
I can recreate this. I'll take a look at why...
On Thu, Feb 20, 2014 at 7:30 AM, kevin wrote:
> Sorry, I should have included the version in my original post.
> I'm using Camel version 2.12.2. with ActiveMQ broker 5.9.0
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabb
Yah, seems SJMS makes a lot of assumptions for you.
Ignoring persistence/ttl for sending to queues (and defaulting to
"PERSISTENT" and no TTL) seems to have been done on purpose.
Maybe we can get Scott ES (created the component) to comment?
On Thu, Feb 20, 2014 at 8:53 AM, Christian Posta
wrote:
Just talked to Scott. This is a bug. I've open a Jira for you here:
https://issues.apache.org/jira/browse/CAMEL-7230
Will work on a patch shortly.
On Thu, Feb 20, 2014 at 9:14 AM, Christian Posta
wrote:
> Yah, seems SJMS makes a lot of assumptions for you.
> Ignoring persistence/ttl for sending
Hello All,
I have developed a Camel route in which there is an XSD validation.
The XSD file has been checked as valid with XML Spy 2014.
When the route is deployed under Karaf or JBoss Fuse, it works.
But When I try to unit test it from Eclipse, I have the following exception
and the route doesn
I understand that the aggregator's messages do not count - they are checked
out during shutdown just fine.
The problem is the 'direct:testInput' route is actively processing a message
(represented by the delay(2*1000)), but the DefaultShutdownStrategy does not
count this message. It begins shutti
Thank you for the quick response, I'll keep an eye out for the patch.
--
View this message in context:
http://camel.465427.n5.nabble.com/sjms-component-ttl-does-not-seem-to-work-tp5747604p5747685.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Sounds that you are running into a parser problem like described here
http://stackoverflow.com/questions/16651005/workaround-for-xmlschema-not-sup
porting-maxoccurs-larger-than-5000
So XML Spy and Fuse are using other parsers than Eclipse.
Jan
> -Ursprüngliche Nachricht-
> Von: ABoucham
Fixed: https://issues.apache.org/jira/browse/CAMEL-7230
On Thu, Feb 20, 2014 at 11:38 AM, kevin wrote:
> Thank you for the quick response, I'll keep an eye out for the patch.
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/sjms-component-ttl-does-not-seem-to-w
I currently have a route that take a message sent to a JMS queue, multicasts
to some sub-queues, and then aggregates the resulting responses to return an
overall status of processing to the client.
This is working well using request-reply over JMS, but I would like to make
the JMS queues transacti
Any advice to give on this issue?
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-validator-parser-doesn-t-allow-a-maxOccurs-attribute-value-to-be-set-greater-than-the-value-5-0-tp5747680p5747692.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Thanks for the patch Christian.
On Thu, Feb 20, 2014 at 2:56 PM, Christian Posta
wrote:
> Fixed: https://issues.apache.org/jira/browse/CAMEL-7230
>
>
>
>
> On Thu, Feb 20, 2014 at 11:38 AM, kevin wrote:
> > Thank you for the quick response, I'll keep an eye out for the patch.
> >
> >
> >
> >
>
Hello,
I have a question about how jetty minThreads/maxThreads settings work in
an OSGi environment where there's multiple bundles consuming from the same
port via the Camel jetty component.
So if I have 2 bundles (bundle1, and bundle2) and they both are consuming
from the same port (for example
Hi,
I have a Camel application design question. My requirement is as following:
1. The data source is from an activemq queue
2. the data is processed by serveral different processors in a row
3. the data is stored in database finally.
The main problem is on my processors threading model. I read
hi,do you have any IBM official instructions?
--
View this message in context:
http://camel.465427.n5.nabble.com/Producer-Template-Failure-on-Glassfish-AIX-tp5734027p5747709.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Try changing the parser?
Jan
> -Ursprüngliche Nachricht-
> Von: ABouchama [mailto:tit...@yahoo.fr]
> Gesendet: Donnerstag, 20. Februar 2014 22:18
> An: users@camel.apache.org
> Betreff: Re: AW: camel-validator : parser doesn't allow a maxOccurs
> attribute value to be set greater than the
Hi
Yeah first one wins.
On Fri, Feb 21, 2014 at 3:42 AM, samslara wrote:
> Hello,
> I have a question about how jetty minThreads/maxThreads settings work in
> an OSGi environment where there's multiple bundles consuming from the same
> port via the Camel jetty component.
>
> So if I have 2 bu
Hi
Yeah sounds like a good idea. Not sure how easy it is with resetting
the counter. As you would need to initialize, on startup, and see how
many files are there already so you avoid a naming clash.
We love contributions. So feel free to log a JIRA and work on patch.
http://camel.apache.org/cont
> I had thought about the possible solutions for this and got 2 ideas:
> 1. create several rows of processors and store the rows in some kind of
> pool. For each data I pick up one row and process it through the
> processes in the that row.
> 2. create different pools for different type of processo
38 matches
Mail list logo
