summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFSchemaRequestCommand.java
diff options
context:
space:
mode:
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.java17
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 + '\'' +
+ '}';
+ }
}