You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2019/07/26 15:27:00 UTC
[qpid-broker-j] 04/07: QPID-8349: Extend broker admin interface
with attributes to identify support of operations to put messages on a
queue and queue deletion
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit 67ad35414d2162a9554c0b026647cdb3908a0e9a
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Wed Jul 24 10:18:30 2019 +0100
QPID-8349: Extend broker admin interface with attributes to identify support of operations to put messages on a queue and queue deletion
---
.../org/apache/qpid/systests/admin/SpawnBrokerAdmin.java | 12 ++++++++++++
.../main/java/org/apache/qpid/tests/utils/BrokerAdmin.java | 2 ++
.../qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java | 12 ++++++++++++
.../qpid/tests/utils/ExternalQpidBrokerAdminImpl.java | 13 +++++++++++++
.../qpid/tests/utils/LoggingBrokerAdminDecorator.java | 12 ++++++++++++
5 files changed, 51 insertions(+)
diff --git a/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java b/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
index c5a076c..9f8ed5e 100644
--- a/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
+++ b/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
@@ -282,6 +282,18 @@ public class SpawnBrokerAdmin implements BrokerAdmin, Closeable
}
@Override
+ public boolean isPutMessageOnQueueSupported()
+ {
+ return true;
+ }
+
+ @Override
+ public boolean isDeleteQueueSupported()
+ {
+ return true;
+ }
+
+ @Override
public String getValidUsername()
{
return "admin";
diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
index 5c4f974..b8acf34 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
@@ -53,6 +53,8 @@ public interface BrokerAdmin extends Pluggable
boolean isWebSocketSupported();
boolean isQueueDepthSupported();
boolean isManagementSupported();
+ boolean isPutMessageOnQueueSupported();
+ boolean isDeleteQueueSupported();
String getValidUsername();
String getValidPassword();
diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
index 1b74bbe..9ba6aed 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
@@ -374,6 +374,18 @@ public class EmbeddedBrokerPerClassAdminImpl implements BrokerAdmin
}
@Override
+ public boolean isPutMessageOnQueueSupported()
+ {
+ return true;
+ }
+
+ @Override
+ public boolean isDeleteQueueSupported()
+ {
+ return true;
+ }
+
+ @Override
public String getValidUsername()
{
return "guest";
diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
index a54df16..db5d44d 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
@@ -173,4 +173,17 @@ public class ExternalQpidBrokerAdminImpl implements BrokerAdmin
{
return EXTERNAL_BROKER;
}
+
+ @Override
+ public boolean isPutMessageOnQueueSupported()
+ {
+ return false;
+ }
+
+ @Override
+ public boolean isDeleteQueueSupported()
+ {
+ return false;
+ }
+
}
diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
index f27df58..6674e3e 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
@@ -157,6 +157,18 @@ public class LoggingBrokerAdminDecorator implements BrokerAdmin
}
@Override
+ public boolean isPutMessageOnQueueSupported()
+ {
+ return _delegate.isPutMessageOnQueueSupported();
+ }
+
+ @Override
+ public boolean isDeleteQueueSupported()
+ {
+ return _delegate.isDeleteQueueSupported();
+ }
+
+ @Override
public String getValidUsername()
{
return _delegate.getValidUsername();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org