[jboss-svn-commits] JBL Code SVN: r25532 - in labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src: test/java/org/drools/runtime/pipeline/impl and 1 other directory.

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

Author: mark.proctor at jboss.com
Date: 2009-03-06 19:14:30 -0500 (Fri, 06 Mar 2009)
New Revision: 25532

Modified:
   labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/main/java/org/drools/runtime/pipeline/impl/JmsMessenger.java
   labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java
Log:
JBRULES-1993 BatchExeution and message format

Modified: labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/main/java/org/drools/runtime/pipeline/impl/JmsMessenger.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/main/java/org/drools/runtime/pipeline/impl/JmsMessenger.java	2009-03-06 21:46:05 UTC (rev 25531)
+++ labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/main/java/org/drools/runtime/pipeline/impl/JmsMessenger.java	2009-03-07 00:14:30 UTC (rev 25532)
@@ -124,15 +124,16 @@
             while ( this.run ) {
                 Message msg = null;
                 try {
-                    msg = this.consumer.receive();
-                    if ( this.resultHandlerFactory != null ) {
-                        pipeline.insert( msg,
-                                         this.resultHandlerFactory.newResultHandler() );
-                    } else {
-                        pipeline.insert( msg,
-                                         null );
+                    msg = this.consumer.receive();     
+                    if (  msg != null ) {
+                        if ( this.resultHandlerFactory != null ) {
+                            pipeline.insert( msg,
+                                             this.resultHandlerFactory.newResultHandler() );
+                        } else {
+                            pipeline.insert( msg,
+                                             null );
+                        }
                     }
-                    System.out.println( "msg received : " + msg );
                 } catch ( JMSException e ) {
                     this.feeder.handleException( this.feeder,
                                                  msg,

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-03-06 21:46:05 UTC (rev 25531)
+++ labs/jbossrules/trunk/drools-pipeline/drools-messenger-jms/src/test/java/org/drools/runtime/pipeline/impl/JaxbSimpleJmsMessengerTest.java	2009-03-07 00:14:30 UTC (rev 25532)
@@ -126,7 +126,7 @@
             if ( factory.list.size() == 1 ) {
                 break;
             }
-            Thread.sleep( 500 );
+            Thread.sleep( 5000 );
         }
 
         FactHandle factHandle = (FactHandle) ((Map) ((ResultHandlerImpl) factory.list.get( 0 )).getObject()).keySet().iterator().next();