diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java')
-rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java index 8c0a5001db..af9322764a 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java +++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java @@ -36,6 +36,7 @@ import javax.management.JMException; import java.util.ArrayList; import java.util.Collections; import java.util.List; +import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArraySet; @@ -103,14 +104,14 @@ public class DirectExchange extends AbstractExchange return DirectExchange.class; } - public DirectExchange newInstance(VirtualHost host, + public DirectExchange newInstance(UUID id, VirtualHost host, AMQShortString name, boolean durable, int ticket, boolean autoDelete) throws AMQException { DirectExchange exch = new DirectExchange(); - exch.initialise(host,name,durable,ticket,autoDelete); + exch.initialise(id, host,name,durable,ticket,autoDelete); return exch; } @@ -131,12 +132,6 @@ public class DirectExchange extends AbstractExchange return new DirectExchangeMBean(this); } - public Logger getLogger() - { - return _logger; - } - - public List<? extends BaseQueue> doRoute(InboundMessage payload) { |