diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2007-01-31 14:23:38 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2007-01-31 14:23:38 +0000 |
| commit | 0b0d16f224e9b556cb4ee4f0b5b8d33f636aefb6 (patch) | |
| tree | 12ac6054275738849f7cc48875cb3b7fa13ad243 /java | |
| parent | 90c5a913d9b394d02797037e991d63530fb75669 (diff) | |
| download | qpid-python-0b0d16f224e9b556cb4ee4f0b5b8d33f636aefb6.tar.gz | |
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
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); } |