[jboss-svn-commits] JBL Code SVN: r23170 - 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 05:31:52 -0400 (Mon, 29 Sep 2008)
New Revision: 23170

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java
Log:
correct action processing time: JBESB-2078

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 09:26:53 UTC (rev 23169)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/message/ActionProcessingPipeline.java	2008-09-29 09:31:52 UTC (rev 23170)
@@ -478,7 +478,7 @@
 
 	private boolean processPipeline(final Message message)
 	{
-		long start = System.nanoTime();
+		final long start = System.nanoTime();
 		final Call callDetails = new Call() ;
 		callDetails.copy(message.getHeader().getCall()) ;
 
@@ -509,6 +509,7 @@
 					final ActionPipelineProcessor processor = processors[count];
 					messages[count] = currentMessage;
 
+					final long actionStart = System.nanoTime();
 					try
 					{
 						LOGGER.debug("executing processor " + count+ " "+processor+" "+message.getHeader());
@@ -552,7 +553,7 @@
 							faultTo(callDetails, Factory.createErrorMessage(Factory.UNEXPECTED_ERROR, message, ex));
 						}
 
-						long procTime = System.nanoTime() - start;
+						long procTime = System.nanoTime() - actionStart;
 						serviceMessageCounter.update(new ActionStatusBean(procTime, count, message,
 							ActionStatusBean.ACTION_FAILED));
 						DeliveryObservableLogger.getInstance().logMessage(new MessageStatusBean(procTime, message,
@@ -564,7 +565,7 @@
 						}
 						return false;
 					}
-					serviceMessageCounter.update(new ActionStatusBean((System.nanoTime() - start), count, message,
+					serviceMessageCounter.update(new ActionStatusBean((System.nanoTime() - actionStart), count, message,
 						ActionStatusBean.ACTION_SENT));
 				}