[jboss-cvs] JBoss Messaging SVN: r2823 - in trunk/src/main/org/jboss/messaging/core: impl and 1 other directory.

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

Author: timfox
Date: 2007-07-02 16:28:46 -0400 (Mon, 02 Jul 2007)
New Revision: 2823

Modified:
   trunk/src/main/org/jboss/messaging/core/contract/Message.java
   trunk/src/main/org/jboss/messaging/core/impl/ChannelSupport.java
Log:
Removed trace route header


Modified: trunk/src/main/org/jboss/messaging/core/contract/Message.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/contract/Message.java	2007-07-02 20:23:06 UTC (rev 2822)
+++ trunk/src/main/org/jboss/messaging/core/contract/Message.java	2007-07-02 20:28:46 UTC (rev 2823)
@@ -38,11 +38,6 @@
 public interface Message extends Streamable
 {
 	/**
-	 * This header can be used to trace a message across the cluster 
-	 */
-   public static final String HEADER_JBM_TRACE_ROUTE = "HEADER_JBM_TRACE_ROUTE";   
-	
-	/**
 	 * This header is set on a message when a message is sucked from one node of the cluster to another
 	 * and order preservation is true.
 	 * The header is checked when sucking messages and if order preservation is true then the message is not accepted.

Modified: trunk/src/main/org/jboss/messaging/core/impl/ChannelSupport.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/ChannelSupport.java	2007-07-02 20:23:06 UTC (rev 2822)
+++ trunk/src/main/org/jboss/messaging/core/impl/ChannelSupport.java	2007-07-02 20:28:46 UTC (rev 2823)
@@ -672,23 +672,7 @@
       ref = ref.copy();
 
       try
-      {  
-      	if (trace)
-   		{
-   			//We add a header that tracks the route of the message across the cluster
-   			
-   			String route = (String)ref.getMessage().getHeader(Message.HEADER_JBM_TRACE_ROUTE);
-   			
-   			if (route == null)
-      		{
-      			route = "nodes:";
-      		}
-   			
-      		route += this + "-";
-      		
-      		ref.getMessage().putHeader(Message.HEADER_JBM_TRACE_ROUTE, route);
-   		}
-      	
+      {        	
          if (tx == null)
          {
             if (persist && ref.getMessage().isReliable() && recoverable)