From 0b0d16f224e9b556cb4ee4f0b5b8d33f636aefb6 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Wed, 31 Jan 2007 14:23:38 +0000 Subject: uncommented mandatory routing check git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501850 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/server/exchange/FanoutExchange.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'java') 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); } -- cgit v1.2.1