Mailing-List: contact camel-user-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: camel-user@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <13278046.post@talk.nabble.com>
Date: Thu, 18 Oct 2007 09:12:21 -0700 (PDT)
From: jmfj <j@j3m.org>
To: camel-user@activemq.apache.org
Subject: Re: Why are both tests failing?
In-Reply-To: <13263902.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <13263902.post@talk.nabble.com>


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.