svn commit: r501850 - /incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java

[rhs]

Author: rhs
Date: Wed Jan 31 06:23:38 2007
New Revision: 501850

URL: http://svn.apache.org/viewvc?view=rev&rev=501850
Log:
uncommented mandatory routing check

Modified:
    
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java

Modified: 
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java?view=diff&rev=501850&r1=501849&r2=501850
==============================================================================
--- 
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java
 (original)
+++ 
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java
 Wed Jan 31 06:23:38 2007
@@ -156,12 +156,11 @@
         if (_queues == null || _queues.isEmpty())
         {
             String msg = "No queues bound to " + this;
-            // XXX
-            /*if (publishBody.mandatory)
+            if (transferBody.mandatory)
             {
                 throw new NoRouteException(msg, payload);
             }
-            else*/
+            else
             {
                 _logger.warn(msg);
             }