[jboss-svn-commits] JBL Code SVN: r24687 - labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl.

[jboss-svn-commits at lists.jboss.org]

Author: mark.proctor at jboss.com
Date: 2009-01-13 18:23:31 -0500 (Tue, 13 Jan 2009)
New Revision: 24687

Modified:
   labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java
   labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/SimpleJmsMessengerTest.java
Log:
JBRULES-1903 Pipeline support for DataLoaders and Feeders 
-Fixed failing JMS test, tearDown needed to be added to close the Broker and consumer

Modified: labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java	2009-01-13 23:21:54 UTC (rev 24686)
+++ labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java	2009-01-13 23:23:31 UTC (rev 24687)
@@ -157,6 +157,7 @@
 
         assertEqualsIgnoreWhitespace( xml,
                                       (String) resultHandler.getObject() );
+        feeder.stop();
 
     }
 

Modified: labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/SimpleJmsMessengerTest.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/SimpleJmsMessengerTest.java	2009-01-13 23:21:54 UTC (rev 24686)
+++ labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/SimpleJmsMessengerTest.java	2009-01-13 23:23:31 UTC (rev 24687)
@@ -103,6 +103,7 @@
         factHandle = (FactHandle) ((Map) ((ResultHandlerImpl) factory.list.get( 3 )).getObject()).keySet().iterator().next();
         assertEquals( "hello3",
                       ksession.getObject( factHandle ) );
+        feeder.stop();
 
     }