diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java index b98daf7cb1..709b59588d 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFBrokerRequestCommand.java @@ -21,6 +21,7 @@ package org.apache.qpid.qmf; +import org.apache.log4j.Logger; import org.apache.qpid.transport.codec.BBDecoder; import org.apache.qpid.transport.codec.BBEncoder; import org.apache.qpid.server.message.ServerMessage; @@ -32,10 +33,14 @@ import org.apache.qpid.AMQException; import org.apache.qpid.management.common.mbeans.ManagedConnection; import java.util.ArrayList; +import java.util.List; public class QMFBrokerRequestCommand extends QMFCommand { + private static final Logger _qmfLogger = Logger.getLogger("qpid.qmf"); + + public QMFBrokerRequestCommand(QMFCommandHeader header, BBDecoder buf) { super(header); @@ -46,6 +51,8 @@ public class QMFBrokerRequestCommand extends QMFCommand String exchangeName = message.getMessageHeader().getReplyToExchange(); String queueName = message.getMessageHeader().getReplyToRoutingKey(); + _qmfLogger.debug("Execute: " + this); + QMFCommand[] commands = new QMFCommand[2]; commands[0] = new QMFBrokerResponseCommand(this, virtualHost); commands[1] = new QMFCommandCompletionCommand(this); @@ -57,7 +64,7 @@ public class QMFBrokerRequestCommand extends QMFCommand QMFMessage responseMessage = new QMFMessage(queueName, cmd); - ArrayList<? extends BaseQueue> queues = exchange.route(responseMessage); + List<? extends BaseQueue> queues = exchange.route(responseMessage); for(BaseQueue q : queues) |