diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java index 11b8061105..6c1db77995 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/FanoutExchange.java @@ -156,12 +156,11 @@ public class FanoutExchange extends AbstractExchange 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); } |