diff options
Diffstat (limited to 'qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management')
2 files changed, 37 insertions, 1 deletions
diff --git a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java index e73d177599..34f08615ad 100644 --- a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java +++ b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java @@ -1071,6 +1071,12 @@ class ManagementNode implements MessageSource, MessageDestination } @Override + public boolean removeAcquisitionFromConsumer(final ConsumerImpl consumer) + { + return false; + } + + @Override public void setRedelivered() { @@ -1119,6 +1125,18 @@ class ManagementNode implements MessageSource, MessageDestination } @Override + public boolean lockAcquisition() + { + return false; + } + + @Override + public boolean unlockAcquisition() + { + return false; + } + + @Override public int getMaximumDeliveryCount() { return 0; 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 |