[jboss-svn-commits] JBL Code SVN: r23178 - labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message.

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

Author: kevin.conner at jboss.com
Date: 2008-09-29 07:31:16 -0400 (Mon, 29 Sep 2008)
New Revision: 23178

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java
Log:
Update statistics: JBESB-2080

Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java	2008-09-29 11:05:19 UTC (rev 23177)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java	2008-09-29 11:31:16 UTC (rev 23178)
@@ -515,14 +515,10 @@
 						LOGGER.debug("executing processor " + count+ " "+processor+" "+message.getHeader());
 
 						currentMessage = processor.process(currentMessage);
-
-						if (currentMessage == null)
-						{
-							break;
-						}
 					}
 					catch (final Exception ex)
 					{
+						final long procTime = System.nanoTime() - actionStart;
 						if (LOGGER.isDebugEnabled())
 						{
 							LOGGER.debug("Unexpected exception caught while processing the action pipeline: "+message.getHeader(),ex);
@@ -553,10 +549,10 @@
 							faultTo(callDetails, Factory.createErrorMessage(Factory.UNEXPECTED_ERROR, message, ex));
 						}
 
-						long procTime = System.nanoTime() - actionStart;
+						final long totalProcTime = System.nanoTime() - start;
 						serviceMessageCounter.update(new ActionStatusBean(procTime, count, message,
 							ActionStatusBean.ACTION_FAILED));
-						DeliveryObservableLogger.getInstance().logMessage(new MessageStatusBean(procTime, message,
+						DeliveryObservableLogger.getInstance().logMessage(new MessageStatusBean(totalProcTime, message,
 							MessageStatusBean.MESSAGE_FAILED));
 
 						if (throwRuntime)
@@ -565,8 +561,14 @@
 						}
 						return false;
 					}
-					serviceMessageCounter.update(new ActionStatusBean((System.nanoTime() - actionStart), count, message,
+					final long procTime = System.nanoTime() - actionStart;
+					serviceMessageCounter.update(new ActionStatusBean(procTime, count, message,
 						ActionStatusBean.ACTION_SENT));
+
+					if (currentMessage == null)
+					{
+						break;
+					}
 				}
 
 				// Reply...