[jboss-cvs] JBoss Messaging SVN: r3358 - branches/Branch_Stable/src/main/org/jboss/messaging/core/impl.

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

Author: timfox
Date: 2007-11-22 05:41:17 -0500 (Thu, 22 Nov 2007)
New Revision: 3358

Modified:
   branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ChannelSupport.java
   branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ClusterRoundRobinDistributor.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-1159


Modified: branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ChannelSupport.java
===================================================================
--- branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ChannelSupport.java	2007-11-22 08:47:18 UTC (rev 3357)
+++ branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ChannelSupport.java	2007-11-22 10:41:17 UTC (rev 3358)
@@ -35,7 +35,6 @@
 import org.jboss.messaging.core.contract.DeliveryObserver;
 import org.jboss.messaging.core.contract.Distributor;
 import org.jboss.messaging.core.contract.Filter;
-import org.jboss.messaging.core.contract.Message;
 import org.jboss.messaging.core.contract.MessageReference;
 import org.jboss.messaging.core.contract.PersistenceManager;
 import org.jboss.messaging.core.impl.tx.Transaction;

Modified: branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ClusterRoundRobinDistributor.java
===================================================================
--- branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ClusterRoundRobinDistributor.java	2007-11-22 08:47:18 UTC (rev 3357)
+++ branches/Branch_Stable/src/main/org/jboss/messaging/core/impl/ClusterRoundRobinDistributor.java	2007-11-22 10:41:17 UTC (rev 3358)
@@ -94,37 +94,37 @@
    	return del;
    }
    
-   public synchronized boolean add(Receiver r)
+   public boolean add(Receiver r)
    {            
    	//FIXME - get the absraction right so this is not necessary
       throw new IllegalStateException("Not used!");     
    }
 
-   public synchronized boolean remove(Receiver r)
+   public boolean remove(Receiver r)
    {      
    	//FIXME - get the absraction right so this is not necessary
       throw new java.lang.IllegalStateException("Not used!"); 
    }
    
-   public synchronized void clear()
+   public void clear()
    {
       localDistributor.clear();
       
       remoteDistributor.clear(); 
    }
 
-   public synchronized boolean contains(Receiver r)
+   public boolean contains(Receiver r)
    {
       return localDistributor.contains(r) || remoteDistributor.contains(r);     
    }
 
-   public synchronized Iterator iterator()
+   public Iterator iterator()
    {
    	//We only count the local ones
       return localDistributor.iterator();      
    }
    
-   public synchronized int getNumberOfReceivers()
+   public int getNumberOfReceivers()
    {
       return localDistributor.getNumberOfReceivers() + remoteDistributor.getNumberOfReceivers();
    }