diff options
Diffstat (limited to 'java')
3 files changed, 6 insertions, 12 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index 3aa9178d5d..d0231e4d80 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -91,14 +91,6 @@ public abstract class AbstractExchange implements Exchange, Managable private final AtomicLong _routedMessageSize = new AtomicLong(); private final CopyOnWriteArrayList<Exchange.BindingListener> _listeners = new CopyOnWriteArrayList<Exchange.BindingListener>(); -/* -======= - public ExchangeMBean() throws NotCompliantMBeanException - { - super(ManagedExchange.class, ManagedExchange.TYPE); - } ->>>>>>> .r902547 -*/ //TODO : persist creation time private long _createTime = System.currentTimeMillis(); diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java index 626ceb5d84..b33a83672b 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java @@ -137,7 +137,7 @@ public abstract class AbstractExchangeMBean<T extends AbstractExchange> extends AMQQueue queue = vhost.getQueueRegistry().getQueue(new AMQShortString(queueName)); if (queue == null) { - throw new JMException("Queue \"" + queueName + "\" is not registered with the exchange."); + throw new JMException("Queue \"" + queueName + "\" is not registered with the virtualhost."); } CurrentActor.set(new ManagementActor(_logActor.getRootMessageLogger())); @@ -164,7 +164,7 @@ public abstract class AbstractExchangeMBean<T extends AbstractExchange> extends AMQQueue queue = vhost.getQueueRegistry().getQueue(new AMQShortString(queueName)); if (queue == null) { - throw new JMException("Queue \"" + queueName + "\" is not registered with the exchange."); + throw new JMException("Queue \"" + queueName + "\" is not registered with the virtualhost."); } CurrentActor.set(new ManagementActor(_logActor.getRootMessageLogger())); diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java index e98a603d12..f9cbfeb78b 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java @@ -251,8 +251,10 @@ public class HeadersExchange extends AbstractExchange bindings.remove(binding); } - _logger.debug("==============="); - _logger.debug("Removing Binding: " + _bindingHeaderMatchers.remove(new HeadersBinding(binding))); + if(_logger.isDebugEnabled()) + { + _logger.debug("Removing Binding: " + _bindingHeaderMatchers.remove(new HeadersBinding(binding))); + } } } |