[jboss-svn-commits] JBL Code SVN: r8457 - in labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners: . gateway

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

Author: estebanschifman
Date: 2006-12-20 16:04:21 -0500 (Wed, 20 Dec 2006)
New Revision: 8457

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/AbstractManagedListener.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
Log:
Cut wait time to smaller slices in listeners

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/AbstractManagedListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/AbstractManagedListener.java	2006-12-20 20:23:43 UTC (rev 8456)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/AbstractManagedListener.java	2006-12-20 21:04:21 UTC (rev 8457)
@@ -234,11 +234,8 @@
 				}
 
 				long lWait = _controller.millisToWait();
-
-				// This if() is just in case (it should never happen - it's a
-				// safety net)
 				if (lWait > 0)
-					waitForEventAndProcess(lWait);
+					waitForEventAndProcess(Math.min(lWait, 100));
 			}
 			setChanged();
 			notifyObservers(Boolean.FALSE);

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2006-12-20 20:23:43 UTC (rev 8456)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2006-12-20 21:04:21 UTC (rev 8457)
@@ -265,7 +265,10 @@
     	while (_controller.continueLooping()) 
         try 
         {
-            return _messageReceiver.receive(_controller.millisToWait());
+        	long lWait = _controller.millisToWait();
+        	if (lWait < 1)
+        		return null;
+            return _messageReceiver.receive(Math.min(lWait,100));
         }
         catch (JMSException oJ)
         {