diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java index 3141676f10..a1260ed9e6 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.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.server.virtualhost.VirtualHost; import org.apache.qpid.server.message.ServerMessage; @@ -31,9 +32,12 @@ import org.apache.qpid.AMQException; import java.util.Collection; import java.util.ArrayList; +import java.util.List; public class QMFSchemaRequestCommand extends QMFCommand { + private static final Logger _qmfLogger = Logger.getLogger("qpid.qmf"); + private final String _packageName; private final String _className; private final byte[] _hash; @@ -48,6 +52,8 @@ public class QMFSchemaRequestCommand extends QMFCommand public void process(VirtualHost virtualHost, ServerMessage message) { + _qmfLogger.debug("Execute: " + this); + String exchangeName = message.getMessageHeader().getReplyToExchange(); String routingKey = message.getMessageHeader().getReplyToRoutingKey(); @@ -70,7 +76,7 @@ public class QMFSchemaRequestCommand extends QMFCommand QMFMessage responseMessage = new QMFMessage(routingKey, cmd); - ArrayList<? extends BaseQueue> queues = exchange.route(responseMessage); + List<? extends BaseQueue> queues = exchange.route(responseMessage); for(BaseQueue q : queues) { @@ -85,4 +91,13 @@ public class QMFSchemaRequestCommand extends QMFCommand } } } + + @Override + public String toString() + { + return "QMFSchemaRequestCommand{" + + " packageName='" + _packageName + '\'' + + ", className='" + _className + '\'' + + '}'; + } } |