diff options
Diffstat (limited to 'qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java')
-rw-r--r-- | qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java index ae2828d392..03e7eab61b 100644 --- a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java +++ b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java @@ -90,6 +90,12 @@ class ManagementResponse implements MessageInstance } @Override + public boolean removeAcquisitionFromConsumer(final ConsumerImpl consumer) + { + return consumer == _consumer; + } + + @Override public void setRedelivered() { _isRedelivered = true; @@ -138,6 +144,18 @@ class ManagementResponse implements MessageInstance } @Override + public boolean lockAcquisition() + { + return false; + } + + @Override + public boolean unlockAcquisition() + { + return false; + } + + @Override public int getMaximumDeliveryCount() { return 0; @@ -190,7 +208,7 @@ class ManagementResponse implements MessageInstance @Override public void delete() { - // TODO + _isDeleted = true; } @Override |