Author: kgiusti
Date: Mon Sep 19 19:54:30 2011
New Revision: 1172776
URL: http://svn.apache.org/viewvc?rev=1172776&view=rev
Log:
QPID-3346: fix the java build
Modified:
qpid/branches/qpid-3346/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFService.java
Modified:
qpid/branches/qpid-3346/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFService.java
URL:
http://svn.apache.org/viewvc/qpid/branches/qpid-3346/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFService.java?rev=1172776&r1=1172775&r2=1172776&view=diff
==============================================================================
---
qpid/branches/qpid-3346/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFService.java
(original)
+++
qpid/branches/qpid-3346/qpid/java/broker/src/main/java/org/apache/qpid/qmf/QMFService.java
Mon Sep 19 19:54:30 2011
@@ -694,7 +694,8 @@ public class QMFService implements Confi
public BrokerSchema.BrokerClass.QueueMoveMessagesMethodResponseCommand
queueMoveMessages(final
BrokerSchema.BrokerClass.QueueMoveMessagesMethodResponseCommandFactory factory,
final String srcQueue,
final String destQueue,
-
final Long qty)
+
final Long qty,
+
final Map filter) // TODO: move based on group identifier
{
// TODO
return
factory.createResponseCommand(CompletionCode.NOT_IMPLEMENTED);
@@ -731,6 +732,14 @@ public class QMFService implements Confi
return
factory.createResponseCommand(CompletionCode.NOT_IMPLEMENTED);
}
+ public BrokerSchema.BrokerClass.QueryMethodResponseCommand query(final
BrokerSchema.BrokerClass.QueryMethodResponseCommandFactory factory,
+ final
String type,
+ final
String name)
+ {
+ //TODO:
+ return
factory.createResponseCommand(CompletionCode.NOT_IMPLEMENTED);
+ }
+
public UUID getId()
{
return _obj.getId();
@@ -1102,7 +1111,8 @@ public class QMFService implements Confi
}
public BrokerSchema.QueueClass.PurgeMethodResponseCommand purge(final
BrokerSchema.QueueClass.PurgeMethodResponseCommandFactory factory,
- final
Long request)
+ final
Long request,
+ final
Map filter) // TODO: support for purge-by-group-identifier
{
try
{
@@ -1118,7 +1128,8 @@ public class QMFService implements Confi
public BrokerSchema.QueueClass.RerouteMethodResponseCommand
reroute(final BrokerSchema.QueueClass.RerouteMethodResponseCommandFactory
factory,
final Long request,
final Boolean useAltExchange,
-
final String exchange)
+
final String exchange,
+
final Map filter) // TODO: support for re-route-by-group-identifier
{
//TODO
return
factory.createResponseCommand(CompletionCode.NOT_IMPLEMENTED);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
