just use a mock result endpoint and assert that the total processing time was
within an acceptable range...
resultEndpoint.expectedMessageCount(100);
long start = System.currentTimeMillis();
//send messages
resultEndpoint.assertIsSatisfied();
assertTrue("took too long", (System.currentTimeMill
On Wed, May 4, 2011 at 6:53 AM, Muhammad Ichsan wrote:
> On Wed, May 4, 2011 at 11:27 AM, boday wrote:
>> here are a few links that might help...
>>
>
> Thanks!
>
> But, how about time limitation? I need to make sure that when sending
> 100 messages in concurrency 20 into a 5s processor, camel ca
On Wed, May 4, 2011 at 11:27 AM, boday wrote:
> here are a few links that might help...
>
Thanks!
But, how about time limitation? I need to make sure that when sending
100 messages in concurrency 20 into a 5s processor, camel can process
20 messages in 5s.
--
~The best men are men who benefit
here are a few links that might help...
http://camel.apache.org/dataset.html
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteTest.java?view=markup
http://benoday.blogspot.com/2011/04/camel-activemq-performance-test
Dear All
I want to load testing my camel so that I know if my configuration -
e.g. concurrentConsumers=10 - can process a 10 messages at one time
concurrently. How to do this? Is there any real example? Thanks
--
~The best men are men who benefit to others
http://michsan.web.id 一緒に勉強しましょう！
Yang
On Tue, May 3, 2011 at 10:00 PM, Claus Straube wrote:
> ok - I see the problem. Try this instead:
>
> public void configure() throws Exception {
>
> from("direct:foo")
> .inOut("activemq:queue:a", "activemq:queue:b")
As far as I know, queue will be used by
Hi,
From the stack trace I can tell is you are using the cxf-http-jetty
transport instead of servlet transport.
Can you double check your beans.xml to make sure you include the
servlet.xml spring configuration like this?
On 5/4/11 2:50 AM, gsilverman wrote:
I don't believe this is correct,
see the http://camel.apache.org/load-balancer.html load balancer page for
details...basically, "The round robin load balancer is not meant to work
with failover, for that you should use the dedicated failover load balancer"
so, see this unit test for an example
http://svn.apache.org/viewvc/came
a couple of quick thoughts...
-if you want load balancing with AMQ, you need a
http://activemq.apache.org/networks-of-brokers.html network of brokers
setup (as opposed to just failover)
-then you can have camel consume from a "distributed" queue (for example)
and let AMQ handle the abstraction/b
Hi All,
I am planning to use camel in such a way that it send messages to three
destinations A,B,C in a round robin manner,what happens if one of the
destinations is not available will camel round robin the message between the
remaining two destinations please suggest.
Thanks
Anurag
--
View this
I get multiple routes in OSGi by having a service that provides a
singleton CamelContext. Bundles consume the same CamelContext and
create on it whatever routes they need.
Though I do this in Java, not Spring, so this might not be what you're
looking for.
Don
On Tue, May 3, 2011 at 5:18 PM, Klu
I'm having some troubles with this as well. Could someone enlighten us what the
best way would be to get multiple routes into a single OSGi application?
-Original Message-
From: Mark Doyle [mailto:markjohndo...@googlemail.com]
Sent: Sun 5/1/2011 10:02 PM
To: users@camel.apache.org
Subje
I don't believe this is correct, simply to change the address in the
cxfEndpoint. I have a similar firewall problem and need to expose a
camel-cxf endpoint running behind a firewall. My endpoint is defined as
follows:
But a client needs to access this from the outside, as
https://someURL:4443/Pr
Yeah there may be a spring specific error handler listener as well.
So you may have
- camel error handler (in the routes)
- jms exception listener
- spring error listener
On Tue, May 3, 2011 at 2:55 PM, bvahdat wrote:
> Hi all,
>
> I would really appreciate it if someone from the camel team co
Hi
Just use the move option on the ftp endpoint (ftp inherits the options
from the file)
http://camel.apache.org/file2
from ftp?move=success
process file
There is also a moveFailed if you want to move files that failed to
some other place.
On Tue, May 3, 2011 at 2:57 PM, kanmisc wrote:
>
I had once again I look into my test code, and discovered that I mixed
something up with TestNGs after*** methods. camelContext.stop() is
working properly. Sorry for the confusion,
marco
On 03.05.2011 14:54, Willem Jiang wrote:
Can I have a look of you test code?
If you shutdown the camel co
ok - I see the problem. Try this instead:
public void configure() throws Exception {
from("direct:foo")
.inOut("activemq:queue:a", "activemq:queue:b")
.to("mock:result");
from("activemq:queue:a")
.bean(f
Hi,
Please check the following link...
http://camel.apache.org/http.html http://camel.apache.org/http.html
At the very bottom of the page, there is a section on how "Setting up SSL
for HTTP Client" to set up that goes over the requirement you have listed.
Cheers,
Ashwin...
-
On Tue, May 3, 2011 at 6:55 PM, Claus Straube wrote:
The problem is not when using "direct", but when using "activemq"
I'm using:
2.6.0
3.0.5.RELEASE
5.4.2
It's still happening in 2.7.1
If you need my code to review, this is the complete artifact
Hello, i need to manage a custom ssl with camel that read a certificate ,
What I do is something like
http://svn.apache.org/repos/asf/httpcomponents/httpclient/branches/4.0.x/httpclient/src/examples/org/apache/http/examples/client/ClientCustomSSL.java.
I'd like to avoid writing a custom bean.
I
Last week, I've been experimenting with PojoSR
(http://code.google.com/p/pojosr/) which looks like a good solution
for testing OSGi stuff in a lightweight way. The idea is that you
don't boot a full OSGi runtime, but rather emulate an OSGi framewokr
in a flat class loader. This project has been i
Hi All
I have a usecase where I need to download a file from ftp server, process
it; if the processing of all the records from the file is success I need to
move the file to different location in the same ftp server.
Issue is - regardless of the route request coming from java class(2), ftp
route
Hi all,
I would really appreciate it if someone from the camel team could provide a
feedback if I'm wrong or not (see my previous post for details).
The only reason why I commented on this topic (although I was not the
original creater of it) was that I've got the same issue on my project, and
ju
Can I have a look of you test code?
If you shutdown the camel context , the cxfconsumer should stop the
server at the same time.
Willem
On 5/3/11 4:52 PM, Marco Zapletal wrote:
Hello,
I have several routes exposing CXF endpoints as consumers. The endpoints
are defined in my camel-config.xml
I was originally getting the queuename from a String (via JNDI) but needed to
create an Endpoint instead..
Now it all works nicely :)
Thanks
Best regards
Ray
--
View this message in context:
http://camel.465427.n5.nabble.com/Odd-stacktrace-when-starting-route-tp4366854p4367058.htm
It also works if I do this:
from("direct:a")
.bean(foo, "doA");
//.to("log:A");
from("direct:b")
.bean(foo, "doB");
//.to("log:B");
On 03.05.2011 13:49, Claus Straube wrote:
Ok - Ichsan :)
This wor
Ok - Ichsan :)
This works for me in 2.8-SNAPSHOT. I think this is pretty close to that
you want to do (except the spring stuff).
public class CamelTestRoutingSlip extends CamelTestSupport {
@EndpointInject(uri = "mock:result")
protected MockEndpoint resultEndpoint;
public void t
Hi
What version of Camel are you using? And try upgrading to latest
released version to see if that helps.
On Tue, May 3, 2011 at 10:23 AM, Muhammad Ichsan wrote:
> Dear All,
>
> Is it possible to use inOut in routingSlip? In the following context,
> the destination is visited asynchronously in
On Tue, May 3, 2011 at 3:49 PM, Claus Straube wrote:
> Hi Muhammad,
Ichsan please :D
>
> I think the error must be in your iMessageUtil class. This route works as
> you would expect:
IMHO, I think it's a bug in Camel. Please look at my testing artifacts:
Java code:
Hi
Can you post the method signatures of your bean?
And do you use any proxy or AOP or spring @annotation stuff on your bean?
On Tue, May 3, 2011 at 12:12 PM, Mond Raymond wrote:
> This looks like issue #CAMEL-1549 but I have tried with 2.4.0 and 2.7.0 so I
> guess there is no regression and t
This looks like issue #CAMEL-1549 but I have tried with 2.4.0 and 2.7.0 so I
guess there is no regression and there must be something else wrong.
Any ideas on where I can look?
Thanks
Ray
[03-05-2011 12:05:39:299] INFO DefaultCamelContext - Apache Camel 2.7.0
(CamelContext: TQS_JMS_BRIDGE) star
Hello,
I have several routes exposing CXF endpoints as consumers. The endpoints
are defined in my camel-config.xml Spring Context using the
definition.
When testing them, I am regularly experiencing a
"java.lang.RuntimeException: Soap 1.1 endpoint already registered on
address http://loca
Hi Muhammad,
I think the error must be in your iMessageUtil class. This route works
as you would expect:
public class CamelTestRoutingSlip extends CamelTestSupport {
public void testRoutingSlip(){
template.sendBody("direct:foo", "foo");
}
protected RouteBuilder createRo
Dear All,
Is it possible to use inOut in routingSlip? In the following context,
the destination is visited asynchronously instead of - my expectation
- synchronously. Why this happens?
http://camel.apache.org/schema/spring";>
34 matches
Mail list logo
