camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jmfj...@j3m.org>
Subject Re: Why are both tests failing?
Date Thu, 18 Oct 2007 19:52:27 GMT

oh boy - how can we make this whole thread vanish ? :)

Thanks !


RomKal wrote:
> 
> Maybe it is because you send messages to mock:eventPublisher while you
> test mock:event-publisher ? ;)
> 
> Romek
> 
> 2007/10/18, jmfj 
>>
>> I am seeing that all processors are receiving and handling these messages
>> as
>> expected, but for some reason the MockEndpoint are either not receiving
>> these messages or not adding up to the total messages received.
>>
>> A MockEndpoint bug? Anything you guys could think of?
>> Thanks
>>
>>
>> jmfj wrote:
>> >
>> >
>> >
>> >       public void testSeda() throws Exception {
>> >               CamelContext context = new DefaultCamelContext();
>> >               context.addRoutes(new RouteBuilder() {
>> >
>> >                       @Override
>> >                       public void configure() throws Exception {
>> >                              
>> from("seda:inbound").convertBodyTo(String.class).process(new
>> > Processor() {
>> >
>> >                                       public void process(Exchange
>> arg0) throws Exception {
>> >                                               System.out.println("proc
>> 3/1: " + arg0 + "/" +
>> > Thread.currentThread());
>> >                                       }
>> >
>> >                               }).to("seda:stage-1");
>> >
>> >                               from("seda:stage-1").process(new
>> Processor() {
>> >
>> >                                       public void process(Exchange
>> arg0) throws Exception {
>> >                                               System.out.println("proc
>> 3/2: " + arg0 + "/" +
>> > Thread.currentThread());
>> >                                       }
>> >
>> >                               }).to("mock:eventPublisher");
>> >
>> >                       }
>> >
>> >               });
>> >
>> >               CamelTemplate template = new CamelTemplate(context);
>> >
>> >               context.start();
>> >
>> >               template.sendBody("seda:inbound",
>> "test-direct-endpoints");
>> >
>> >               MockEndpoint eventPubilsher =
>> > context.getEndpoint("mock:event-publisher", MockEndpoint.class);
>> >               eventPubilsher.expectedMessageCount(1);
>> >
>> >               MockEndpoint.assertIsSatisfied(1, TimeUnit.SECONDS,
>> eventPubilsher);
>> >
>> >               context.stop();
>> >       }
>> >
>> >       public void testDirect() throws Exception {
>> >               CamelContext context = new DefaultCamelContext();
>> >               context.addRoutes(new RouteBuilder() {
>> >
>> >                       @Override
>> >                       public void configure() throws Exception {
>> >                              
>> from("seda:inbound").convertBodyTo(String.class).process(new
>> > Processor() {
>> >
>> >                                       public void process(Exchange
>> arg0) throws Exception {
>> >                                               System.out.println("proc
>> 2/1: " + arg0 + "/" +
>> > Thread.currentThread());
>> >                                       }
>> >
>> >                               }).to("direct:stage-1");
>> >
>> >                               from("direct:stage-1").process(new
>> Processor() {
>> >
>> >                                       public void process(Exchange
>> arg0) throws Exception {
>> >                                               System.out.println("proc
>> 2/2: " + arg0 + "/" +
>> > Thread.currentThread());
>> >                                       }
>> >
>> >                               }).to("mock:eventPublisher");
>> >
>> >                       }
>> >
>> >               });
>> >
>> >               CamelTemplate template = new CamelTemplate(context);
>> >
>> >               context.start();
>> >
>> >               template.sendBody("seda:inbound",
>> "test-direct-endpoints");
>> >
>> >               MockEndpoint eventPubilsher =
>> > context.getEndpoint("mock:event-publisher", MockEndpoint.class);
>> >               eventPubilsher.expectedMessageCount(1);
>> >
>> >               eventPubilsher.assertIsSatisfied();
>> >
>> >               context.stop();
>> >       }
>> >
>> > Exceptions traces are respectivelly:
>> >
>> > java.lang.AssertionError: Timeout waiting for endpoints to receive
>> enough
>> > messages. mock:event-publisher timed out.
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.assertWait(MockEndpoint.java:73)
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:83)
>> >       at
>> >
>> xxxx.actions.common.route.CommonRouteTest.testSeda(CommonRouteTest.java:93)
>> >       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>> >       at
>> >
>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>> >       at
>> >
>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>> >       at java.lang.reflect.Method.invoke(Method.java:585)
>> >       at junit.framework.TestCase.runTest(TestCase.java:164)
>> >       at junit.framework.TestCase.runBare(TestCase.java:130)
>> >       at junit.framework.TestResult$1.protect(TestResult.java:106)
>> >       at junit.framework.TestResult.runProtected(TestResult.java:124)
>> >       at junit.framework.TestResult.run(TestResult.java:109)
>> >       at junit.framework.TestCase.run(TestCase.java:120)
>> >       at junit.framework.TestSuite.runTest(TestSuite.java:230)
>> >       at junit.framework.TestSuite.run(TestSuite.java:225)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
>> >
>> >
>> > and
>> >
>> > java.lang.AssertionError: mock:event-publisher Received message count.
>> > Expected: <1> but was: <0>
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.fail(MockEndpoint.java:511)
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.assertEquals(MockEndpoint.java:493)
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:148)
>> >       at
>> >
>> org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:125)
>> >       at
>> >
>> xxx.actions.common.route.CommonRouteTest.testDirect(CommonRouteTest.java:133)
>> >       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>> >       at
>> >
>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>> >       at
>> >
>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>> >       at java.lang.reflect.Method.invoke(Method.java:585)
>> >       at junit.framework.TestCase.runTest(TestCase.java:164)
>> >       at junit.framework.TestCase.runBare(TestCase.java:130)
>> >       at junit.framework.TestResult$1.protect(TestResult.java:106)
>> >       at junit.framework.TestResult.runProtected(TestResult.java:124)
>> >       at junit.framework.TestResult.run(TestResult.java:109)
>> >       at junit.framework.TestCase.run(TestCase.java:120)
>> >       at junit.framework.TestSuite.runTest(TestSuite.java:230)
>> >       at junit.framework.TestSuite.run(TestSuite.java:225)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
>> >       at
>> >
>> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
>> >
>> > Thanks !!
>> >
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Why-are-both-tests-failing--tf4643641s22882.html#a13278046
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>>
> 
> 

-- 
View this message in context: http://www.nabble.com/Why-are-both-tests-failing--tf4643641s22882.html#a13282330
Sent from the Camel - Users mailing list archive at Nabble.com.


Mime
View raw message