svn commit: r1407395 - /camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java

[da...@apache.org]

Author: davsclaus
Date: Fri Nov  9 09:32:19 2012
New Revision: 1407395

URL: http://svn.apache.org/viewvc?rev=1407395&view=rev
Log:
Fixed test

Modified:
    camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java

Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java?rev=1407395&r1=1407394&r2=1407395&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java Fri Nov  9 09:32:19 2012
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.component.mina;
 
-import java.lang.reflect.Field;
 import java.util.ArrayList;
 import java.util.List;
 import javax.naming.Context;
@@ -39,22 +38,23 @@ public class MinaFiltersTest extends Bas
 
     @Test
     public void testFilterListRef() throws Exception {
-        testFilter("mina:tcp://localhost:{{port}}?textline=true&minaLogger=true&sync=false&filters=#myFilters");
+        testFilter(String.format("mina:tcp://localhost:%1$s?textline=true&minaLogger=true&sync=false&filters=#myFilters", getPort()));
     }
 
     @Test
     public void testFilterElementRef() throws Exception {
-        testFilter("mina:tcp://localhost:{{port}}?textline=true&minaLogger=true&sync=false&filters=#myFilter");
+        testFilter(String.format("mina:tcp://localhost:%1$s?textline=true&minaLogger=true&sync=false&filters=#myFilter", getPort()));
     }
 
     @Override
-    public void tearDown() throws Exception {
+    public void setUp() throws Exception {
         TestFilter.called = 0;
-        super.tearDown();
+        super.setUp();
     }
 
     private void testFilter(final String uri) throws Exception {
         context.addRoutes(new RouteBuilder() {
+
             public void configure() throws Exception {
                 from(uri).to("mock:result");
             }
@@ -72,16 +72,11 @@ public class MinaFiltersTest extends Bas
         exchange.getIn().setBody("Hello World");
         producer.process(exchange);
 
-        Field field = producer.getClass().getDeclaredField("session");
-        field.setAccessible(true);
-        IoSession session = (IoSession) field.get(producer);
-        assertTrue("There should be a test filter", session.getFilterChain().contains(TestFilter.class.getCanonicalName()));
+        assertMockEndpointsSatisfied();
 
-        assertTrue("The filter should have been called twice (producer and consumer)", TestFilter.called == 2);
+        assertEquals("The filter should have been called twice (producer and consumer)", 2, TestFilter.called);
 
         producer.stop();
-
-        assertMockEndpointsSatisfied();
     }
 
     @Override